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

Swoole 中的 SwooleCoroutineBarrier 是一个协程同步工具,用于等待一组协程全部执行完成。它类似于“屏障”或“栅栏”,所有协程在到达屏障前会阻塞,直到最后一个协程到达后,所有协程才一起继续执行。这个功能在需要并发执行多个任务并等待它们全部结束时非常有用。
1. Barrier 的基本用法
SwooleCoroutineBarrier 提供了两个核心方法:SwooleCoroutineBarrier::make() 创建屏障句柄,SwooleCoroutineBarrier::wait() 用于协程加入屏障等待。
当所有协程都调用了 wait() 后,屏障自动释放,所有等待的协程恢复运行。
示例:并发请求并等待全部完成
假设我们要并发发起多个网络请求,并确保所有请求完成后才继续处理:
use SwooleCoroutine;use SwooleCoroutineBarrier;Coroutineun(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]});
2. Barrier 与 Group 协程的区别
有些人可能会混淆 Barrier 和使用 Channel 或 WaitGroup 实现的协程组管理。关键区别在于:
如知AI笔记
如知笔记——支持markdown的在线笔记,支持ai智能写作、AI搜索,支持DeepseekR1满血大模型
27 查看详情
Barrier 不关心协程执行顺序或返回值传递,只关注“是否全部到达”不需要手动计数,只要每个协程都调用一次 Barrier::wait() 即可实现更简洁,适合简单的“汇合”场景
3. 注意事项和常见用法
使用 Barrier 时需要注意以下几点:
必须在 Coroutineun() 内使用,否则无法创建协程环境每个参与同步的协程(包括主协程)都应调用 Barrier::wait()调用次数必须等于参与协程的数量,多或少都会导致死锁或提前释放Barrier 句柄通过 Barrier::make() 创建,是一个 int 类型的句柄
小技巧:可用于初始化多个服务依赖
例如微服务启动时,需要并行加载配置、连接数据库、注册服务等,可用 Barrier 等待全部准备就绪:
“`phpBarrier::wait($barrier); // 主协程等待echo “所有初始化任务完成,服务启动中…”;“`
基本上就这些。SwooleCoroutineBarrier 虽然简单,但在需要协程“汇合”的场景下非常实用,代码清晰且不易出错。关键是理解它的“一次性同步点”语义:所有人到了才能继续走。不复杂但容易忽略细节。
以上就是Swoole中如何使用SwooleCoroutineBarrier的详细内容,更多请关注php中文网其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/577905.html
微信扫一扫
支付宝扫一扫