require 'socket'

@queue = Ractor.new do
  loop do
    Ractor.yield(Ractor.receive, move: true)
  end
end

listener = Ractor.new(@queue) do |queue|
  socket = TCPServer.new(PORT)
  puts "Listening to the port #{PORT}..."

  loop do
    client = socket.accept

    queue.send(client, move: true)
  end
end

workers = CPUS.times.map do
  Ractor.new(@queue) do |queue|
    loop do
      client = queue.take

      client.puts("HTTP/1.1 200\r\nContent-Type: text/html\r\n\r\n<h1>Yo</h1>")
      client.close
    end
  end
end

loop do
  Ractor.select(listener, *workers)
end