php 中的协程轻量级线程,可在不占用过多资源的情况下并发处理任务。创建协程使用 go() 函数,并通过 run() 或 await() 启动。可通过 send() 发送值,通过 recv() 接收值。实战用例包括异步处理 http 请求,从而提升服务器吞吐量和并发处理能力。

PHP 的协程:创建与使用
协程是轻量级的线程,在不占用过多系统资源的情况下,可以并发处理多个任务。PHP 自 8.1 版本起支持协程,扩充了该语言的并发处理能力。
创建协程
立即学习“PHP免费学习笔记(深入)”;
要创建协程,可以使用 go() 函数:
go()函数会接收一个匿名函数作为参数。这个函数即构成了协程要执行的任务。启动协程
创建协程后,还需要手动启动它。有两种方式可以启动协程:
ECTouch移动商城系统下载ECTouch是上海商创网络科技有限公司推出的一套基于 PHP 和 MySQL 数据库构建的开源且易于使用的移动商城网店系统!应用于各种服务器平台的高效、快速和易于管理的网店解决方案,采用稳定的MVC框架开发,完美对接ecshop系统与模板堂众多模板,为中小企业提供最佳的移动电商解决方案。ECTouch程序源代码完全无加密。安装时只需将已集成的文件夹放进指定位置,通过浏览器访问一键安装,无需对已有
- 同步启动:使用
run()函数:$result = $coroutine->run();
- 异步启动:使用
await()函数:$result = await $coroutine;异步启动可以让协程在主线程完成后再执行,而同步启动则会立即执行协程。
发送值到协程
可以向协程发送值,就像使用
yield表达式发送值给生成器一样:$coroutine->send('Hello');从协程接收值
也可以从协程接收值。这可以通过
recv()方法实现:$value = $coroutine->recv();实战案例
以下是一个使用协程异步处理 HTTP 请求的示例:
use Amp\Http\Server\Server; use Amp\Http\Server\Request; use Amp\Http\Server\Response; use Amp\Http\Server\Middleware; $middleware = Middleware::wrap(function (Request $request, Response $response) { // 协程:处理请求并发送响应 $coroutine = go(function () use ($request, $response) { // ... $response->writeHead(200, ['Content-Type' => 'text/plain']); $response->end('Hello, world!'); }); return $coroutine; }); $server = new Server('0.0.0.0', 8000, $middleware); $server->start();在该示例中,协程被用作中间件,来异步处理传入的 HTTP 请求。这可以显著提高服务端的吞吐量和并发处理能力。











