前言
第一部分: 半协程调度器
- 统一生成器接口
- 生成器迭代
- 生成器返回值
- 生成器委托
- 改写 return
- 抽象异步模型
- 引入异常处理
- 异常: 嵌套任务透传
- 异常: 传递流程
- 异常: 重新进行 CPS 变换
- 异常: 重新加入 Async
- Syscall 与 Context
- 调度器: 里程碑
- spawn
- callcc
- race 与 timeout
- all 与 parallel
- channel 与协程间通信
- 无缓存 channel
- 缓存 channel
- channel 演示
- FutureTask 与 fork
第二部分: Koa
- 穿越地心之旅
- 洋葱圈模型
- rightReduce与中间件compose
- Koa::Application
- Koa::Context
- Koa::Request
- Koa::Response
- Koa - HelloWorld
- Middleware Interface
- Middleware: 全局异常处理
- Middleware: Router
- Middleware: 请求超时
- 一个综合示例
附录
参考
文章来源于网络收集而来,版权归原创者所有,如有侵权请及时联系!
生成器迭代
生成器迭代
手动迭代生成器,递归执行 AsyncTask::next
,调用Generator::send
方法将将yield值作为yield表达式结果。
- yield表达式可能是一个异步调用,我们这里为之后把异步调用的结果作为yield表达式结果铺垫。
- yield外侧括号在PHP5必须,PHP7不需要。
如, $ip = (yield async_dns_lookup(...) );
^ |--------------------|
| yield值
| |---------------------------|
yield表达式结果 yield 表达式
<?php
final class AsyncTask
{
public $gen;
public function __construct(\Generator $gen)
{
$this->gen = new Gen($gen);
}
public function begin()
{
$this->next();
}
public function next($result = null)
{
$value = $this->gen->send($result);
if ($this->gen->valid()) {
$this->next($value);
}
}
}
<?php
function newGen()
{
$r1 = (yield 1);
$r2 = (yield 2);
echo $r1, $r2;
}
$task = new AsyncTask(newGen());
$task->begin(); // output: 12
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论