Parallel

Parallel 是一個并行任務調(diào)度工具，允許在程序中同時執(zhí)行多個異步任務，并在所有任務完成后獲取結果。Parallel是基于Barrier實現(xiàn)的。

注意
底層自動識別驅(qū)動類型，僅支持Swoole/Swow/Fiber驅(qū)動

提示
此特性需要 workerman>=5.1.0

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Parallel;
use Workerman\Events\Swoole;
use Workerman\Protocols\Http\Request;
use Workerman\Worker;
require_once __DIR__ . '/vendor/autoload.php';

// Http Server
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // Or Swow::class or Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $parallel = new Parallel();
    for ($i=1; $i<5; $i++) {
        $parallel->add(function () use ($i) {
            // Do something
            return $i;
        });
    }
    $results = $parallel->wait();
    $connection->send(json_encode($results)); // Response: [1,2,3,4]
};
Worker::runAll();

接口說明

interface ParallelInterface
{
    /**
     * 構造函數(shù)，$concurrent為并行任務數(shù)，-1表示不限制并行任務數(shù)
     */
    public function __construct(int $concurrent = -1);

    /**
     * 添加一個并行任務
     */
    public function add(callable $callable, ?string $key = null): void;

    /**
     * 等待所有任務完成并返回結果
     */
    public function wait(): array;

    /**
     * 獲取任務中發(fā)生異常的結果
     */
    public function getExceptions(): array;
}