Invoker

EasySwoole为了让框架支持函数超时处理和swoole1.x与2.x,封装了一个Invoker。

实现代码

  1. namespace EasySwoole\Core\Component;
  4. use EasySwoole\Core\Swoole\ServerManager;
  5. use \Swoole\Process;
  6. use \Swoole\Coroutine;
  8. class Invoker
  9. {
  10.     /*
  11.      *  Async::set([
  12.           'enable_signalfd' => false,
  13.        ]);
  14.      */
  15.     public static function exec(callable $callable,$timeOut = 100 * 1000,...$params)
  16.     {
  17.         pcntl_async_signals(true);
  18.         pcntl_signal(SIGALRM, function () {
  19.             Process::alarm(-1);
  20.             throw new \RuntimeException('func timeout');
  21.         });
  22.         try
  23.         {
  24.             Process::alarm($timeOut);
  25.             $ret = self::callUserFunc($callable,...$params);
  26.             Process::alarm(-1);
  27.             return $ret;
  28.         }
  29.         catch(\Throwable $throwable)
  30.         {
  31.             throw $throwable;
  32.         }
  33.     }
  36.     public static function callUserFunc(callable $callable,...$params)
  37.     {
  38.         if(ServerManager::getInstance()->isCoroutine()){
  39.             return Coroutine::call_user_func($callable,...$params);
  40.         }else{
  41.             return call_user_func($callable,...$params);
  42.         }
  43.     }
  45.     public static function callUserFuncArray(callable $callable,array $params)
  46.     {
  47.         if(ServerManager::getInstance()->isCoroutine()){
  48.             return Coroutine::call_user_func_array($callable,$params);
  49.         }else{
  50.             return call_user_func_array($callable,$params);
  51.         }
  52.     }
  53. }

使用实例

限制函数执行时间

  1. try{
  2.     \EasySwoole\Core\Component\Invoker::exec(function (){
  3.         sleep(2);
  4.     });
  5. }catch (Throwable $throwable){
  6.     echo $throwable->getMessage();
  7. }