yurunsoft/xcoroutine

The PHP Coroutine.

v0.1.1-stable 2017-08-17 00:26 UTC

This package is auto-updated.

Last update: 2024-06-13 20:43:57 UTC


README

XCoroutine, the PHP Coroutine.

此仓库版本为宇润基于 xtlsoft/XCoroutine 项目开发,增加协程挂起、恢复功能。

本项目遵循 MIT 开源协议发布,并提供免费使用。

install 安装

composer require yurunsoft/xcoroutine

Intro 介绍

  • Task: 任务实例。您可以向里面传入一个Generator,然后通过我们的封装对他进行操作。
  • Scheduler: 多任务执行封装。您可以往里面add许多Task,然后执行。每个Task有唯一的ID,一个Task进行部分计算调用yield后,让下一个Task进行计算,以此循环,实现多任务管理。
  • SystemCall: Task之间和Task与Scheduler之间传递数据、互相操作的接口。
  • DynamicObject: 动态编程类,让你的类支持动态定义/销毁变量和方法。

Usage 使用

  1. 初识yield 例子:
    <?php
        
        foreach(range(1,10) as $i){
            echo $i." ";
        }
        echo "<br>\n";
        
        function xrange($a,$b,$c=1){
            for($i = $a; $a <= $b; $i+=$c){
                yield $i;
            }
        }
        
        foreach(xrange(1,10) as $i){
            echo $i." ";
        }
        
    输出:
    1 2 3 4 5 6 7 8 9 10
    1 2 3 4 5 6 7 8 9 10
  2. Task 使用 例子:
    <?php
        require "vendor/autoload.php";
        use Coroutine\Task;
        
        function TaskExample(){
            while(true){
                $text = (yield);
                echo "TaskRecv $text <br />\n";
            }
        }
        
        $Task = new Task(TaskExample());
        $Task->run();
        $Task->run("A Test Text 1");
        $Task->setSendValue("Another Test Text");
        $Task->run();
        
    输出:
    TaskRecv A Test Text 1 
    TaskRecv Another Test Text 
  3. Scheduler 使用 例子#1:
    <?php
        require_once "vendor/autoload.php";
        use Coroutine\Scheduler;
        
        function TaskExample($num){
            for($i=0; $i<10; ++$i){
                echo "Task$num RUN $i <br>\n";
                yield;
            }
        }
        
        $scheduler = new Scheduler();
        $scheduler->newTask(TaskExample(1));
        $scheduler->newTask(TaskExample(2));
        $scheduler->newTask(TaskExample(3));
        
        $scheduler->run();
    例子#2:
    <?php
        require_once "vendor/autoload.php";
        use Coroutine\Scheduler;
        
        function t1(){
            for($i=0; $i<10; ++$i){
                echo "t1 RUN $i <br>\n";
                yield;
            }
        }
        function t2(){
            for($i=0; $i<10; ++$i){
                echo "t2 RUN $i <br>\n";
                yield;
            }
        }
        
        $scheduler = new Scheduler();
        $scheduler->newTask(t1());
        $scheduler->newTask(t2());
        
        $scheduler->run();
  4. SystemCall 使用 例子:
    <?php
        require_once "vendor/autoload.php";
        use Coroutine\Scheduler;
        use Coroutine\SystemCall;
        
        function TaskExample($num){
            //获取TaskId
            $tid = (yield SystemCall::getTaskId());
            
            for($i=0; $i<10; ++$i){
                echo "Task$num $tid RUN $i <br>\n";
                if($i == 3){
                    yield SystemCall::killTask(1);
                }
                if($i == 5){
                    yield SystemCall::newTask(Task2());
                }
                yield;
            }
        }
        
        function Task2(){
            $tid = (yield SystemCall::getTaskId());
            for($i=0; $i<3; ++$i){
                echo "Another Task $tid RUN $i <br>\n";
            }
        }
        
        $scheduler = new Scheduler();
        $scheduler->newTask(TaskExample(1));
        $scheduler->newTask(TaskExample(2));
        $scheduler->newTask(TaskExample(3));
        
        $scheduler->run();
  5. DynamicObject 使用 例子:
    <?php
        require("vendor/autoload.php");
        use Coroutine\DynamicObject;
        
        $obj = new DynamicObject;
        
        $obj->abcd = 123;
        
        $obj->myFunc = function($a) use ($obj){
            return ("\$a * abcd = ".($a * $obj->abcd)."<br />\n");
        };
        
        echo $obj->myFunc(2);
        
        unset($obj->abcd);
        
        echo $obj->myFunc(1);
        
        $obj->myFunc = function($a, $b){
            return ("\$a + \$b = ".($a+$b)."<br />\n");
        };
        
        $obj->myFunc(123,321);