异步任务

    在服务启动后的任意一个地方，都可以进行异步任务的投递，为了简化异步任务的投递，框架封装了任务管理器，用于投递同步/异步任务，投递任务有两种方式，一是直接投递闭包，二是投递任务模板类

    任务比较简单的情况下可以直接投递闭包，任意地方包括控制器/定时器/服务启动后的各种回调中均可进行投递

    2. $a=1;//使用外部变量将不存在
    3. TaskManager::async(function ($image,$a) {
    4.     var_dump($image);
    5.     var_dump($a);
    6.     $this->testFunction();//使用外部对象的引用将出错
    7.     return true;
    8. },function () {});

    当任务比较复杂，逻辑较多而且固定时，可以预先创建任务模板，并直接投递任务模板，以简化操作和方便在多个不同的地方投递相同的任务，首先需要创建一个任务模板

    1. class Task extends \EasySwoole\EasySwoole\Swoole\Task\AbstractAsyncTask
    2. {
    4.     /**
    5.      * 执行任务的内容
    6.      * @param mixed $taskData     任务数据
    7.      * @param int   $taskId       执行任务的task编号
    8.      * @param int   $fromWorkerId 派发任务的worker进程号
    9.      * @author : evalor <master@evalor.cn>
    10.      */
    11.     function run($taskData, $taskId, $fromWorkerId,$flags = null)
    12.     {
    13.         // 每个worker进程的编号都是从0开始
    14.         // 所以 $fromWorkerId + $taskId 才是绝对唯一的编号
    15.         // !!! 任务完成需要 return 结果
    16.     }
    18.     /**
    19.      * 任务执行完的回调
    20.      * @param mixed $result  任务执行完成返回的结果
    21.      * @param int   $task_id 执行任务的task编号
    22.      * @author : evalor <master@evalor.cn>
    23.      */
    24.     function finish($result, $task_id)
    25.     {
    26.         // 任务执行完的处理
    27.     }
    28. }

    然后同上例，一样可以在服务启动后的任何地方进行投递，只是将闭包换成任务模板类的实例进行投递

    可通过继承EasySwoole\EasySwoole\Swoole\Task\QuickTaskInterface,增加run方法,即可实现一个任务模板,通过直接投递类名运行任务:

    1. <?php
    2. namespace App\Task;
    3. use EasySwoole\EasySwoole\Swoole\Task\QuickTaskInterface;
    5. class QuickTaskTest implements QuickTaskInterface
    6. {
    7.     static function run(\swoole_server $server, int $taskId, int $fromWorkerId,$flags = null)
    8.     {
    9.         echo "快速任务模板";
    11.     }
    1. $result = TaskManager::async(\App\Task\QuickTaskTest::class);

    由于自定义进程的特殊性，不能直接调用Swoole的异步任务相关方法进行异步任务投递，框架已经封装好了相关的方法方便异步任务投递，请看下面的例子

    有时需要同时执行多个异步任务，最典型的例子是数据采集，采集完多个数据后集中进行处理，这时可以进行并发任务投递，底层会将任务逐个进行投递并执行，所有任务执行完后返回一个结果集

    1. // 多任务并发
    2. $tasks[] = function () { sleep(50000);return 'this is 1'; }; // 任务1
    3. $tasks[] = function () { sleep(2);return 'this is 2'; };     // 任务2
    4. $tasks[] = function () { sleep(50000);return 'this is 3'; }; // 任务3
    6. $results = \EasySwoole\EasySwoole\Swoole\Task\TaskManager::barrier($tasks, 3);
    8. var_dump($results);
    1. /**
    2.  * 投递一个异步任务
    3.  * @param mixed $task           需要投递的异步任务
    4.  * @param mixed $finishCallback 任务执行完后的回调函数
    5.  * @param int   $taskWorkerId   指定投递的Task进程编号 (默认随机投递给空闲进程)
    6.  * @return bool 投递成功 返回整数 $task_id 投递失败 返回 false
    7.  */
    8. static function async($task,$finishCallback = null,$taskWorkerId = -1)
    1. /**
    2.  * 异步进程内投递任务
    3.  * @param array $taskList 需要执行的任务列表
    4.  * @param float $timeout  任务执行超时
    5.  * @return array|bool 每个任务的执行结果
    6.  */
    7. static function barrier(array $taskList, $timeout = 0.5)