協程屏障 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 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) {
    $barrier = Barrier::create();
    for ($i=1; $i<5; $i++) {
        Coroutine::create(function () use ($barrier, $i) {
            // 做一些事情
        });
    }
    // 等待所有協程完成
    Barrier::wait($barrier);
    $connection->send('所有任務完成');
};

Worker::runAll();

接口說明

interface BarrierInterface
{
    /**
     * 創建一個新的 Barrier 實例
     */
    public static function create(): object;

    /**
     * 暫停當前協程，等待指定 Barrier 中的所有協程任務完成
     */
    public static function wait(object &$barrier, int $timeout = -1): void;
}