いくつかの (<50) タスクの後、ワーカーが停止します。
非常に単純なクライアント/ワーカーのセットアップがあります。クライアントは を介してタスクを送信しfunc.delay(...)、while ループに入り、すべてのタスクの完了を待ちます (つまり、 のready()メソッドをチェックしAsyncResultます)。rabbitmqブローカーと結果のバックエンドに使用します。
セットアップは機能します...しばらくの間。いくつかのタスクの後、クライアントは何も受信せず、ワーカーはアイドル状態のようです (コンソールに出力がありません)。
(私が使用しているマシンは少し古いため、リソースの問題は不可能ではありません。それでも、2 秒間実行される 50 のタスクでは、システムの負荷が高いとは言えません)。