🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
# swoole_server->taskCo 并发执行`Task`并进行协程调度。仅用于`2.0`版本。 ```php function swoole_server->taskCo(array $tasks, float $timeout = 0.5) : array; ``` * `$tasks`任务列表,必须为数组。底层会遍历数组,将每个元素作为`task`投递到`Task`进程池 * `$timeout`超时时间,默认为`0.5`秒,当规定的时间内任务没有全部完成,立即中止并返回结果 * 任务完成或超时,返回结果数组。结果数组中每个任务结果的顺序与`$tasks`对应,如:`$tasks[2]`对应的结果为`$result[2]` * 某个任务执行失败或超时,对应的结果数组项为`false`,如:`$tasks[2]`失败了,那么`$result[2]`的值为`false` > 最大并发任务不得超过`1024` > `taskCo`在`2.0.9`或更高版本可用 调度过程 ---- * `$tasks`列表中的每个任务会随机投递到一个`Task`工作进程,投递完毕后,`yield`让出当前协程,并设置一个`$timeout`秒的定时器 * 在`onFinish`中收集对应的任务结果,保存到结果数组中。判断是否所有任务都返回了结果,如果为否,继续等待。如果为是,进行`resume`恢复对应协程的运行,并清除超时定时器 * 在规定的时间内任务没有全部完成,定时器先触发,底层清除等待状态。将未完成的任务结果标记为`false`,立即`resume`对应协程 使用示例 ---- ```php <?php $server = new Swoole\Http\Server("127.0.0.1", 9502, SWOOLE_BASE); $server->set([ 'worker_num' => 1, 'task_worker_num' => 2, ]); $server->on('Task', function (swoole_server $serv, $task_id, $worker_id, $data) { echo "#{$serv->worker_id}\tonTask: worker_id={$worker_id}, task_id=$task_id\n"; if ($serv->worker_id == 1) { sleep(1); } return $data; }); $server->on('Request', function ($request, $response) use ($server) { $tasks[0] = "hello world"; $tasks[1] = ['data' => 1234, 'code' => 200]; $result = $server->taskCo($tasks, 0.5); $response->end('Test End, Result: '.var_export($result, true)); }); $server->start(); ```