Swoole\Coroutine\Barrier用于协程同步，通过make()创建屏障、wait()等待所有协程到达，实现并发任务的汇合。示例中并发请求并等待全部完成，主协程与子协程均调用wait()，确保所有网络请求结束后再继续执行。与Group不同，Barrier不关注顺序和返回值，只需调用一次wait()即可，适用于简单汇合场景。使用时需在Coroutine\run()内，确保调用次数与协程数一致，避免死锁。常用于服务初始化等依赖并行任务完成的场景，语义清晰且易用。
Swoole 中的 Swoole\Coroutine\Barrier 是一个协程同步工具，用于等待一组协程全部执行完成。它类似于“屏障”或“栅栏”，所有协程在到达屏障前会阻塞，直到最后一个协程到达后，所有协程才一起继续执行。这个功能在需要并发执行多个任务并等待它们全部结束时非常有用。
1. Barrier 的基本用法
Swoole\Coroutine\Barrier 提供了两个核心方法：Swoole\Coroutine\Barrier::make() 创建屏障句柄，Swoole\Coroutine\Barrier::wait() 用于协程加入屏障等待。
当所有协程都调用了 wait() 后，屏障自动释放，所有等待的协程恢复运行。
示例：并发请求并等待全部完成
假设我们要并发发起多个网络请求，并确保所有请求完成后才继续处理：
use Swoole\Coroutine;
use Swoole\Coroutine\Barrier;
Coroutine\run(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 Swoole\Coroutine\Http\Client(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]
});2. Barrier 与 Group 协程的区别
有些人可能会混淆 Barrier 和使用 Channel 或 WaitGroup 实现的协程组管理。关键区别在于：
- Barrier 不关心协程执行顺序或返回值传递，只关注“是否全部到达”
- 不需要手动计数，只要每个协程都调用一次 Barrier::wait() 即可
- 实现更简洁，适合简单的“汇合”场景
3. 注意事项和常见用法
使用 Barrier 时需要注意以下几点：
- 必须在 Coroutine\run() 内使用，否则无法创建协程环境
- 每个参与同步的协程（包括主协程）都应调用 Barrier::wait()
- 调用次数必须等于参与协程的数量，多或少都会导致死锁或提前释放
- Barrier 句柄通过 Barrier::make() 创建，是一个 int 类型的句柄
小技巧：可用于初始化多个服务依赖
例如微服务启动时，需要并行加载配置、连接数据库、注册服务等，可用 Barrier 等待全部准备就绪：
```php Barrier::wait($barrier); // 主协程等待 echo "所有初始化任务完成，服务启动中...\n"; ```基本上就这些。Swoole\Coroutine\Barrier 虽然简单，但在需要协程“汇合”的场景下非常实用，代码清晰且不易出错。关键是理解它的“一次性同步点”语义：所有人到了才能继续走。不复杂但容易忽略细节。
