如果有仔細看過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;
// 处理数据
}
如果消費不到數據,就sleep 5ms,sleep的時間依次累加,直到達到最大值100ms,達到cpu 使用率和處理數據實時性的一個平衡,具體平衡點可以根據自己的業務按需調整。
以上是swoole task會阻塞麼的詳細內容。更多資訊請關注PHP中文網其他相關文章!