我們啟動celery基本命令為：

celery -A mytask worker --loglevel=info

當以此命令啟動celery後，celery預設情況下執行任務會有個預取機制（prefetching），預取是什麼呢，如下一張圖：

我們假設有兩個worker，但當任務量較多的時候，celery有個任務佇列，每個wroker執行完了，就從這個佇列中取任務接著執行。但當有預取機制時，佇列中每個task，有了自己的明確限制，就是我這個任務需要指定的worker去執行，就算其他worker是空閒狀態，也不能拿到我執行。

celery可能是考慮到公平性問題，即每個worker所執行的任務數量是要均等的。但是，這樣有一個問題，當某個任務需要執行很長時間，導致這個任務佔用的worker一直得不到釋放，這時候任務佇列中被這個不被釋放的worker預取的任務，一直在等待，並且，其他空閒worker想要取任務，但是都被這個等待的任務阻塞。整個celery都講陷入等待。

如何解決上述問題呢？

啟動celery的命令加上：

celery -A mytask worker --loglevel=info -Ofair

當加上-Ofair時，celery將取消預取機制，如下圖：

這樣，只要有空閒worker，就會從任務佇列中去取任務，保證任務高效執行。這樣也就導致每個worker執行的任務量有差距了。