From 555d653288e58cabac396aea693b78e5b1308add Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Tue, 18 Jan 2022 10:18:13 +0800 Subject: [PATCH] =?UTF-8?q?Revert=20"=E6=94=B9=E5=90=8D"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit fdf58326 --- kiri-task/AsyncTaskExecute.php | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/kiri-task/AsyncTaskExecute.php b/kiri-task/AsyncTaskExecute.php index 26b0ce52..c9ab5924 100644 --- a/kiri-task/AsyncTaskExecute.php +++ b/kiri-task/AsyncTaskExecute.php @@ -6,6 +6,7 @@ use Exception; use Kiri; use Kiri\Abstracts\Component; use Kiri\Server\SwooleServerInterface; +use Swoole\Coroutine; /** @@ -18,7 +19,6 @@ class AsyncTaskExecute extends Component use TaskResolve; - /** * @param OnTaskInterface|string $handler * @param array $params @@ -27,13 +27,14 @@ class AsyncTaskExecute extends Component */ public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = -1) { + if (is_string($handler)) { + $handler = $this->handle($handler, $params); + } + $server = Kiri::getDi()->get(SwooleServerInterface::class); if ($workerId < 0 || $workerId > $server->setting['task_worker_num']) { $workerId = random_int(0, $server->setting['task_worker_num'] - 1); } - if (is_string($handler)) { - $handler = $this->handle($handler, $params); - } $server->task(serialize($handler), $workerId); }