Ruby：线程和套接字

Question

我正在尝试用 Ruby 编写一个服务器连接，它会生成一个线程来处理传入连接。然后，该线程将解释传入的数据，然后将一些指令放入队列中，以供主程序循环在其方便时处理。但是，我似乎对队列处理有一些问题，因为程序似乎在某处阻塞，或者主循环只是意外停止工作。这有点难以解释，这里是我的服务器套接字的监听方法：

def listen
  @socket = TCPServer.open(@ip, @port)

  while @looping do
    puts "Waiting for socket accept"
    server = @socket.accept
    puts "Socket accepted"
    serverloop = Thread.new do
      puts "Waiting for response"
      response = server.read
      puts "Command received: #{response}"
      parse_command(response)
      puts "Response complete"
    end 
    processloop = Thread.new do
      while @looping do  
        process_command_queue
        process_response_queue
      end 
    end 
    if interrupted
      exit
    end 
  end 
end

def process_command_queue
  puts "In the command queue"
  if @command_queue.length > 0 
    @command = @queue.pop
    @command.process
  end 
end

建立连接后，输出如下：

magicked$ ./server.rb 
Waiting for socket accept
Socket accepted
Waiting for response
In the command queue
In the command queue ... (repeats)
Waiting for socket accept
In the command queue
In the command queue ... (repeats a lot)
Command received: EXEC 1 1 thisisacommand
Command initialized: EXEC 1 1 thisisacommand
Response complete

在此之后，它再次暂停并等待另一个连接/命令。我期望看到的是“在命令队列中”继续重复。

我可能还没有完全理解红宝石线程的工作方式。我知道 ruby​​ 解释器的实例在执行多个线程时有限制。那么循环是否再次到达@socket.accept 并且它在等待另一个连接时阻塞了其他指令？我的第一个线程是否完成并与主线程重新连接，导致第二个线程做同样的事情？我是否需要 fork 另一个 ruby​​ 解释器来处理其中一个？

最后，有没有人推荐一个很好的资源来帮助解释更高级的 ruby​​ 线程？我发现了很多简单的例子，但显然我还有很多困惑。

感谢您的帮助！

Answer 1

你应该使用eventmachine。