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的數據