关于PHP中协程和阻塞的一些理解与思考

前言

本文主要给大家介绍了关于PHP中协程和阻塞的理解与思考，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍：

进程、线程、协程

关于进程、线程、协程，有非常详细和丰富的博客或者学习资源，我不在此做赘述，我大致在此介绍一下这几个东西。

PHP中的协程实现基础 yield

yield的根本实现是生成器类，而迭代器类是迭代器接口的实现：

Generator implements Iterator { public mixed current ( void ) // 返回当前产生的值 public mixed key ( void ) // 返回当前产生的键 public void next ( void ) // 生成器继续执行 public void rewind ( void ) // 重置迭代器，如果迭代已经开始了，这里会抛出一个异常。   // renwind的执行将会导致第一个yield被执行, 并且忽略了他的返回值. public mixed send ( mixed $value ) // 向生成器中传入一个值，并且当做 yield 表达式的结果，然后继续执行生成器。如果当这个方法被调用时，生成器    // 不在 yield 表达式，那么在传入值之前，它会先运行到第一个 yield 表达式。 public void throw ( Exception $exception ) // 向生成器中抛入一个异常 public bool valid ( void ) // 检查迭代器是否被关闭 public void __wakeup ( void ) // 序列化回调，抛出一个异常以表示生成器不能被序列化。}

以上解析可以参考PHP官方文档。

http://php.net/manual/zh/clas...

以及这篇详细文档：

//www.jb51.net/article/39424_all.htm

我就以他实现的协程多任务调度为基础做一下例子说明并说一下关于我在阻塞方面所做的一些思考。

自定义简单定时执行任务示例：

(此例子必须依赖于以上鸟哥实现的协程调度代码)

class timer { private $start = 0; // 定时开始时间 private $timer; // 间隔的时间差，单位秒 private $value = 0; // 产生的结果值 private $callback; // 异步回调 private $isEnd = false; // 当前定时器任务是否结束 public function __construct($timer,callable $callback) { $this->start = time(); $this->timer = $timer; $this->callback = $callback; } public function run() { if($this->valid()) { $callback = $this->callback; $callback($this->value ++,$this); $this->start = time(); } } /** * 定时执行检查 */ public function valid() { $end = time(); if($end - $this->start >= $this->timer) { return true; } else { return false; } } public function setEnd($isEnd) { $this->isEnd = $isEnd; } public function getEnd() { return $this->isEnd; }}/** * 模拟阻塞的协程1 * */function taskObject1() { $timer = new timer(1,function($value,timer $timer) { if($value >= 5) { $timer->setEnd(true); } echo '<br>'.'A '.$value; }); $tid = (yield getTaskId()); while (true) { if($timer->getEnd() == true) { break; } yield $timer->run(); }}/** * 模拟阻塞的协程2 * */function taskObject2() { $timer = new timer(2,function($value,timer $timer) { if($value >= 3) { $timer->setEnd(true); } echo '<br>'.'B '.$value; }); $tid = (yield getTaskId()); while (true) { if($timer->getEnd() == true) { break; } yield $timer->run(); }}$scheduler = new Scheduler;$scheduler->newTask(taskObject1());$scheduler->newTask(taskObject2());$scheduler->run();