同步任务串行执行通过Hyperf协程并行提速-php教程-PHP中文网

协程并行不等于“加go就快”，根本原因在于底层调用若非协程安全（如原生curl、PDO），会阻塞整个worker，导致表面并行实则串行排队；必须使用协程化组件（如hyperf/guzzle）并配合WaitGroup或Channel正确同步，同时避免隐藏的同步黑洞。

同步任务串行执行通过hyperf协程并行提速

协程并行不等于“加 go 就快”

直接把原来串行的 sleep(2)、$client->get()、$db->query() 包进 go() 或 Coroutine::create()，不一定提速，甚至更慢。根本原因是：如果底层调用不是协程安全的（比如用 curl_exec、PDO::query），那这个协程一执行就会阻塞整个 worker，其他协程全卡住——表面是“并行”，实际是“排队等一个同步调用结束”。

必须确认你用的组件是否协程化：

hyperf/guzzle（不是原生 Guzzle）✅
hyperf/db（基于 Swoole MySQL 协程客户端）✅
hyperf/redis（封装了 Swoole\Coroutine\Redis）✅
原生 curl、file_get_contents、PDO ❌

用 WaitGroup 控制并行边界和收口

多个协程并发发请求后，不能靠 usleep() 或随机 sleep() 等结果。正确做法是用 Hyperf\Utils\WaitGroup 显式等待全部完成，避免竞态或提前返回空数据。

常见错误写法：

$wg = new \Hyperf\Utils\WaitGroup();
$wg->add(2);
go(function () use ($wg) {
    $this->clientFactory->create()->get('https://api.a');
    $wg->done();
});
go(function () use ($wg) {
    $this->clientFactory->create()->get('https://api.b');
    $wg->done();
});
// ❌ 这里没等，直接 return，结果为空
return 'done';

正确写法：

$wg = new \Hyperf\Utils\WaitGroup();
$wg->add(2);
$responses = [];
go(function () use ($wg, &$responses) {
    $res = $this->clientFactory->create()->get('https://api.a');
    $responses['a'] = (string) $res->getBody();
    $wg->done();
});
go(function () use ($wg, &$responses) {
    $res = $this->clientFactory->create()->get('https://api.b');
    $responses['b'] = (string) $res->getBody();
    $wg->done();
});
$wg->wait(); // ✅ 阻塞当前协程，直到两个子协程都调用了 done()
return $responses;

Channel 适合需要按序消费或流式传递结果的场景

如果你的并行任务产出结果有先后依赖、需要合并、或要控制消费节奏（比如只取前 N 条），Swoole\Coroutine\Channel 比全局数组 + WaitGroup 更合适，也更符合协程调度语义。

Hyperframes Creative

HyperFrames视频非动画创意指导，包括设计规范（frame.md/design.md）处理、配色、字体设计、旁白及节奏规划等。

下载

注意点：

$channel->push() 是协程安全的，但若缓冲区满（默认容量为 1），会阻塞当前协程，直到有协程 pop() —— 所以建议显式设容量：new Channel(10)
不要在非协程环境（如命令行脚本未启动 event loop）中用 Channel，会报 Invalid argument: channel is not available
多个生产者往同一 Channel 推数据时，消费者 pop() 获取顺序取决于协程调度，不保证与 push 顺序一致