2016-11-29 136 views
0

我正在用django的芹菜。我有多個生產者推進一個隊列,有多個工人。 Celery隊列的默認執行順序是FIFO。有時恰好有一個生產者產生了大量的任務,這使得其他生產者在執行完該生產者的所有任務之前都處於飢餓狀態。對於所有生產者來說,執行任務有沒有什麼辦法可以做到公平?更改順序芹菜工隊從隊列中執行任務

回答

0

我有多個生產者正在推進一個隊列,[...]有沒有什麼辦法對所有生產者執行任務有某種公平性?

最公平的解決方案似乎是你爲每個生產者使用一個單獨的隊列。