Swoole中如何使用Swoole\Coroutine\Barrier-Swoole-PHP中文网

Swoole中如何使用SwooleCoroutineBarrier

下次还敢

发布： 2025-09-27 12:52:01

原创

181人浏览过

SwooleCoroutineBarrier用于协程同步，通过make()创建屏障、wait()等待所有协程到达，实现并发任务的汇合。示例中并发请求并等待全部完成，主协程与子协程均调用wait()，确保所有网络请求结束后再继续执行。与Group不同，Barrier不关注顺序和返回值，只需调用一次wait()即可，适用于简单汇合场景。使用时需在Coroutine un()内，确保调用次数与协程数一致，避免死锁。常用于服务初始化等依赖并行任务完成的场景，语义清晰且易用。

$swoole中如何使用swoole\coroutine\barrier$

Swoole 中的 SwooleCoroutineBarrier 是一个协程同步工具，用于等待一组协程全部执行完成。它类似于“屏障”或“栅栏”，所有协程在到达屏障前会阻塞，直到最后一个协程到达后，所有协程才一起继续执行。这个功能在需要并发执行多个任务并等待它们全部结束时非常有用。

1. Barrier 的基本用法

SwooleCoroutineBarrier 提供了两个核心方法：SwooleCoroutineBarrier::make() 创建屏障句柄，SwooleCoroutineBarrier::wait() 用于协程加入屏障等待。

当所有协程都调用了 wait() 后，屏障自动释放，所有等待的协程恢复运行。

示例：并发请求并等待全部完成

假设我们要并发发起多个网络请求，并确保所有请求完成后才继续处理：

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

use SwooleCoroutine;
use SwooleCoroutineBarrier;

Coroutine
un(function () {
    $barrier = Barrier::make();

    $urls = [
        'https://httpbin.org/delay/1',
        'https://httpbin.org/delay/2',
        'https://httpbin.org/delay/1',
    ];

    $results = array_fill(0, count($urls), null);

    foreach ($urls as $i => $url) {
        Coroutine::create(function () use ($barrier, $url, $i, &$results) {
            $client = new SwooleCoroutineHttpClient(parse_url($url, PHP_URL_HOST), 443, true);
            $client->set(['timeout' => 5]);
            $client->get(parse_url($url, PHP_URL_PATH));
            $results[$i] = $client->getStatusCode();
            $client->close();

            // 每个协程执行完后调用 wait，表示到达屏障
            Barrier::wait($barrier);
        });
    }

    // 主协程也等待屏障，直到所有子协程都调用了 Barrier::wait()
    Barrier::wait($barrier);

    // 所有请求完成，输出结果
    var_dump($results); // 输出类似 [200, 200, 200]
});

登录后复制