코루틴 배리어 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
{
    /**
     * 새로운 Barrier 인스턴스를 생성합니다.
     */
    public static function create(): object;

    /**
     * 현재 코루틴을 일시 중지하고, 지정된 Barrier 내의 모든 코루틴 작업이 완료될 때까지 기다립니다.
     */
    public static function wait(object &$barrier, int $timeout = -1): void;
}