CoroutineRunner
協程執行器 CoroutineRunner類似于Csp組件，但更加靈活，可以投遞協程任務并限制最大同時執行數、最長執行時間、成功或失敗回調
簡單示例
use co;
use EasySwoole\Component\CoroutineRunner\Runner;
use EasySwoole\Component\CoroutineRunner\Task;
$runner = new Runner(10);
$runner->setOnException(function(\Throwable $e, $task){
echo $e->getMessage();
echo PHP_EOL;
});
$max = 30;
$allTask = [];
while($max>0){
$task = new Task(function() use ($max) {
echo $max .PHP_EOL;
co::sleep(1);
// 將設這是一個curl爬取任務 return 爬取結果 可以在外部獲取
return 'ok';
});
$runner->addTask($task);
$allTask[] = $task;
$max--;
}
$runner->start(1);// 最長執行1秒 總共投遞了30個 最大并發10個 需要3秒執行完，所以會有一部分將被丟棄 看下方參數說明列表
foreach($allTask as $key => $task){
var_dump($task->getResult());
}
參數說明
Runner構造函數
可接收兩個參數 __construct($concurrency = 64,$taskChannelSize = 1024)
- concurrency 最大同時執行的協程數量
- taskChannelSize 可投遞的task隊列長度
Runner->setOnException
設置異常回調 有兩個參數 (\Throwable $e, Task $task)
Runner->start
開啟已經投遞的task協程的執行，有一個參數
- float $waitTime = 30 最長執行時間，如果超過這個時間，剩余的task協程將被丟棄，不再執行。
Task構造函數
需要一個callable參數，用于調用執行，可以在閉包內return數據，外部使用 $task->getResult()獲取
- return 不等于 false的數據將會觸發onSuccess
- return false 將會觸發 onFail
Task->setOnSuccess
需要一個callable參數
【非必選】 task執行完成回調
Task->setOnFail
需要一個callable參數
【非必選】 task執行失敗回調
Task->getResult
獲取call函數執行后return的數據