如果有仔細看過 swoole task 的文檔的話，應該都會注意到這句話

task操作的次數必須小于onTask處理速度，如果投遞容量超過處理能力，task會塞滿緩存區，導致worker進程發生阻塞。

worker進程將無法接收新的請求 （推薦學習： swoole視頻教程）

task 如果阻塞會引發 woker 進程阻塞，造成服務無法工作，引發問題。

我曾經使用 task 發送服務的鏈路日志，接收日志的服務出現bug，造成發送日志的 task 阻塞，然后服務 gg 的情況，之后我就對 task 做了一波優化。

思路就是使用 swoole channel 和 swoole user process 實現一套 task 。

使用 channel 接收數據，然后在 user process 消費數據，假如 channel 滿了僅僅會造成 push 數據失敗，并不會引發阻塞，因為是鏈路日志，是允許丟失的，所以這個方案完全沒問題。

在swoole user process 消費 channel 的策略的偽代碼如下

$sleepTime = 5;
$maxSleepTime = 100;
while (true) {
 $task = $chan->pop();
 if ($task === false) {
 $sleepTime = $sleepTime + 5;
 if ($sleepTime > $maxSleepTime) {
 $sleepTime = $maxSleepTime;
 }
 usleep($sleepTime * 1000);
 continue;
 }
 $sleepTime = 0;
 // 處理數據
}

如果消費到channel的數據，就使用死循環處理數據，因為處理數據過程中是有其他操作的，所以并不會占用大量 cpu。

如果消費不到數據，就 sleep 5ms，sleep的時間依次累加，直到達到最大值 100ms，達到 cpu 使用率和處理數據實時性的一個平衡，具體平衡點可以根據自己的業務按需調整。

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com