我的工人在完成几项 (<50) 任务后停下来。
我有一个非常简单的客户端/工作者设置。客户端通过发布任务func.delay(...)
然后进入一个while循环等待所有任务完成(即检查ready()
方法AsyncResult
)。我rabbitmq
用于代理和结果后端。
设置工作......一段时间。完成几项任务后,客户端没有收到任何内容,并且工作人员似乎处于空闲状态(控制台中不再有输出)。
(我工作的机器有点旧,所以资源问题并非不可能。不过,在运行 2 秒的 50 个任务时,我不能说系统负载很重)。