swoole task會不會阻塞

這篇文章將為大家詳細講解有關swoole task會不會阻塞，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

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

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

worker進程將無法接收新的請求

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

關于“swoole task會不會阻塞”這篇文章就分享到這里了，希望以上內容可以對大家有一定的幫助，使各位可以學到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。