有没有办法让 Resque 平均分配给定的工作？

Question

我有 5 个这样的 Resque 工作人员设置：

QUEUE=* rake environment resque:work
QUEUE=* rake environment resque:work
QUEUE=* rake environment resque:work

当我像这样从事繁重的工作时：

100.times do 
Resque.enqueue(DoTheJob)
end

第一个工人得到大约 80 份工作，其他工人分担剩下的……

就我而言，我可能有 40 个并发且非常繁重的工作 - 视频转码 -。它们将被连续触发，我希望将工作平等地或至少公平地分配给我现有的员工（最多可有 30 个）。

有什么选择吗？

我怎样才能做到这一点？

谢谢

Answer 1

好吧，当我用一个最简单的 Resque worker 类结构尝试上面的代码时：

class MyWorker 
@queue=:test

def self.perform(data)

puts "Testing...."

end

end

100.times do 
Resque.enqueue(MyWorker)
end

所有作业都排在同一个工作人员的队列中。

但是。

当我给工人几秒钟 sleep 时，我发现工作被相当公平地分配了。

class MyWorker @queue=:test

def self.perform(data)

puts "Testing...."
sleep 3
end

end

我不知道 Resque 为此目的的算法是什么，但看起来没有问题。