异步任务

参考DEMO：异步任务处理

异步任务管理器类：EasySwoole\Core\Swoole\Task\TaskManager

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

直接投递闭包

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

  1. // 在控制器中投递的例子
  2. function index()
  3. {
  4.     \EasySwoole\Core\Swoole\Task\TaskManager::async(function () {
  5.         echo "执行异步任务...\n";
  6.         return true;
  7.     }, function () {
  8.         echo "异步任务执行完毕...\n";
  9.     });
  10. }
  12. // 在定时器中投递的例子
  13. \EasySwoole\Core\Swoole\Time\Timer::loop(1000, function () {
  14.     \EasySwoole\Core\Swoole\Task\TaskManager::async(function () {
  15.         echo "执行异步任务...\n";
  16.     });
  17. });

投递任务模板类

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

异步任务模板类：EasySwoole\Core\Swoole\Task\TaskManager

  1. class Task extends \EasySwoole\Core\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)
  12.     {
  13.         // 需要注意的是task编号并不是绝对唯一
  14.         // 每个worker进程的编号都是从0开始
  15.         // 所以 $fromWorkerId + $taskId 才是绝度唯一的编号
  16.         // !!! 任务完成需要 return 结果
  17.     }
  19.     /**
  20.      * 任务执行完的回调
  21.      * @param mixed $result  任务执行完成返回的结果
  22.      * @param int   $task_id 执行任务的task编号
  23.      * @author : evalor <master@evalor.cn>
  24.      */
  25.     function finish($result, $task_id)
  26.     {
  27.         // 任务执行完的处理
  28.     }
  29. }

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

  1. // 在控制器中投递的例子
  2. function index()
  3. {
  4.     // 实例化任务模板类 并将数据带进去 可以在任务类$taskData参数拿到数据
  5.       $taskClass = new Task('taskData');
  6.     \EasySwoole\Core\Swoole\Task\TaskManager::async($taskClass);
  7. }
  9. // 在定时器中投递的例子
  10. \EasySwoole\Core\Swoole\Time\Timer::loop(1000, function () {
  11.     \EasySwoole\Core\Swoole\Task\TaskManager::async($taskClass);
  12. });

任务并发执行

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

  1. $tasks[] = function () { sleep(50000); }; // 任务1
  2. $tasks[] = function () { sleep(2); };     // 任务2
  3. $tasks[] = function () { sleep(50000); }; // 任务3
  5. $results = \EasySwoole\Core\Swoole\Task\TaskManager::barrier($tasks, 0.5);

注意：Barrier为阻塞等待执行，所有的任务会被分发到不同Task进程同步执行， 直到所有的任务执行结束或超时才返回全部结果，默认的任务超时为0.5秒，所以只有任务1和任务3能成功执行并返回结果

类函数参考

  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 mixed $task         需要投递的异步任务
  4.  * @param float $timeout      任务超时时间
  5.  * @param int   $taskWorkerId 指定投递的Task进程编号 (默认随机投递给空闲进程)
  6.  * @return bool|string 投递成功 返回整数 $task_id 投递失败 返回 false
  7.  */
  8. static function sync($task, $timeout = 0.5, $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)