如何在eventmachine中启动多个工作进程？

Question

我使用的是Rails3、eventmachine和rabbitmq。

当我将消息发布到一个队列时，我需要启动多个工作进程。

我知道eventmachine是我的场景的解决方案。

有些任务会比其他任务花费更长的时间。

使用eventmachine，从大多数代码示例看，在任何给定的时间都只有一个线程/进程会运行。

如何一次启动2-4个工作进程？

Answer 1

如果您使用EM.defer方法，那么您传递给它的每个进程都将被放入线程池(默认为20个线程)。如果您更改EM.threadpool_size，您可以拥有任意多个worker。

worker = Proc.new do
# log running job
end

EM.defer(worker)