PHPはコルーチンを実装します

サーバー プログラミングでは、非同期実装を実現するために、次のようなコールバック関数が必要になることがよくあります。

function send($value) {    $data = process($value);    onReceive($data);}function onReceive($recv_value) {    var_dump($recv_value);}function process($value) {    return $value+1;}$send_value = 1;send($send_value);

実際、実装されているのは、send_value を送信することです。エンドサーバーがリモートエンドに追加した後、それを送り返すため、onReceiveでリモートサーバーの戻り値recv_valueを取得できます。

しかし、そのようなコードは断片的に見え、特にプロセス内でリモート プロシージャ呼び出しが再度行われる場合、開発と保守がより困難になります。コルーチンは、このような問題を解決し、非同期コードを同期的に見せるように設計されています。

以下は、PHP の yield を使用してコードのスケジューリングを完了する例です (このコードを理解したい場合は、まず PHP 5.5 の新機能、ジェネレーターと yield を理​​解する必要があります)

フレームワークのコードは次のとおりです。

class CCoroutine {    /**     *     * @var Generator      */    public $coroutine;    /**     *     * @var miexed null or CCoroutine     */    public $father;    public function __construct($coroutine, $father = null) {        $this->coroutine = $coroutine;        $this->father = $father;    }}class AsyncTask {        public $data;    public function __construct($data) {        $this->data = $data;    }}abstract class CoroutineScheduler {        protected $coroutine = NULL;    abstract function send_and_receive($value);    public function run($data) {        $co = $this->send_and_receive($data);        $ccoroutine = new CCoroutine($co);        $this->schedule($ccoroutine);    }    protected function schedule($ccoroutine) {        $task = $ccoroutine->coroutine->current();        //如果当前值为空，表示这个$ccoroutine应该已经结束了        if (is_null($task)) {            if (is_null($ccoroutine->father)) {            //已经彻底调度结束了--一般是onRecieve方法运行到最后一步了                return;            } else {            //注意，如果运行到这个分支，则表示子生成器没有给父生成器传数据            //子生成器可能是通过引用传递来改变父生成器的变量值            //所以这个时候只要调度父生成器就可以了                $ccoroutine->father->coroutine->next();                $father = $ccoroutine->father;                $this->schedule($father);                unset($ccoroutine);            }        } else {            if (is_object($task) && $task instanceof AsyncTask) {                //当task是异步数据请求的时候，开始处理socket并且将进程熄火在这里                $this->dealTask($task, $ccoroutine);            } elseif (is_object($task) && $task instanceof \Generator) {                //当task是生成器时，表示当前生成器又有了子生成器的调用                $newcc = new CCoroutine($task, $ccoroutine);                $this->schedule($newcc);            } elseif ($ccoroutine->father != null) {                //注意，如果运行到这个分支，则表示在子的生成器里调用了yield $str;这样的写法                //我们规定这种写法是在给父生成器传数据，所以当前生成器就会终止调用了转而去调度父生成器                $ccoroutine->father->coroutine->send($task);                $father = $ccoroutine->father;                $this->schedule($father);                unset($ccoroutine);            }        }    }    protected function dealTask($task, $ccoroutine) {        $this->coroutine = $ccoroutine;        $this->send($task->data);    }        public function send($value) {        $data = $this->process($value);        $this->onReceive($data);    }    public function process($value) {        return $value+1;    }        protected function onReceive($data) {        $this->coroutine->coroutine->send($data);        $this->schedule($this->coroutine);    }}

S 将 フレームはすべて Send、onReceive などの関数によってカプセル化されるため、呼び出し元のコードは同期コードのように見えます

コードは次のようになります。