swoole task會阻塞麼

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

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

worker流程將無法接收新的請求                            中（建議學習： swoole) 若阻塞為程式碼

##wask##wask##wor 程式碼#w服務無法工作，引發問題。

我曾經使用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 使用率和處理數據實時性的一個平衡，具體平衡點可以根據自己的業務按需調整。

以上是swoole task會阻塞麼的詳細內容。更多資訊請關注PHP中文網其他相關文章！