コルーチンバリア Barrier

Barrier はコルーチンの同期に使用されるツールで、非同期タスクの中で、すべてのコルーチンの実行が完了するのを待ってから、後続のロジックを続行することを可能にします。Barrier は PHP の参照カウントに基づいて実装されています。

注意
バリアは底層で自動的にドライバタイプを識別し、Swoole/Swow/Fiber ドライバのみをサポートします。

ヒント
この機能は workerman>=5.1.0 が必要です。

<?php
use Workerman\Connection\TcpConnection;
use Workerman\Coroutine\Barrier;
use Workerman\Coroutine;
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) {
    $barrier = Barrier::create();
    for ($i=1; $i<5; $i++) {
        Coroutine::create(function () use ($barrier, $i) {
            // 何かをする
        });
    }
    // すべてのコルーチンが完了するのを待つ
    Barrier::wait($barrier);
    $connection->send('すべてのタスクが完了しました');
};

Worker::runAll();

インターフェース説明

interface BarrierInterface
{
    /**
     * 新しいバリアインスタンスを作成する
     */
    public static function create(): object;

    /**
     * 現在のコルーチンを一時停止し、指定されたバリア内のすべてのコルーチンタスクが完了するのを待つ
     */
    public static function wait(object &$barrier, int $timeout = -1): void;
}