Parallel

Parallel は、プログラム内で複数の非同期タスクを同時に実行し、すべてのタスクが完了した後に結果を取得するための並行タスクスケジューリングツールです。Parallel は Barrier を基にしています。

注意
下層は自動的にドライバの種類を認識し、Swoole/Swow/Fiber ドライバのみをサポートしています。

ヒント
この機能は 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 サーバー
$worker = new Worker('http://0.0.0.0:8001');
$worker->eventLoop = Swoole::class; // または Swow::class または Fiber::class
$worker->onMessage = function (TcpConnection $connection, Request $request) {
    $parallel = new Parallel();
    for ($i=1; $i<5; $i++) {
        $parallel->add(function () use ($i) {
            // 何かを行う
            return $i;
        });
    }
    $results = $parallel->wait();
    $connection->send(json_encode($results)); // レスポンス: [1,2,3,4]
};
Worker::runAll();

インターフェース説明

interface ParallelInterface
{
    /**
     * コンストラクタ、$concurrent は並行タスク数、-1 は並行タスク数に制限なしを意味します
     */
    public function __construct(int $concurrent = -1);

    /**
     * 並行タスクを追加します
     */
    public function add(callable $callable, ?string $key = null): void;

    /**
     * すべてのタスクの完了を待ち、結果を返します
     */
    public function wait(): array;

    /**
     * タスク中に発生した例外の結果を取得します
     */
    public function getExceptions(): array;
}