From 97a5deda23f7782b66b08e042ff91591e56ec773 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=90=91=E6=9E=97?= Date: Wed, 1 Dec 2021 15:28:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Tasker/AsyncTaskExecute.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Tasker/AsyncTaskExecute.php b/Tasker/AsyncTaskExecute.php index c37fed1..f0ef74c 100644 --- a/Tasker/AsyncTaskExecute.php +++ b/Tasker/AsyncTaskExecute.php @@ -68,9 +68,9 @@ class AsyncTaskExecute extends BaseObject $this->server = Kiri::getDi()->get(SwooleServerInterface::class); } if ($workerId === null || $workerId <= $this->server->setting['worker_num']) { - $workerNum = $this->server->setting['worker_num'] + 1; + $workerNum = $this->server->setting['worker_num']; $taskerNum = $workerNum + $this->server->setting['task_worker_num']; - $workerId = random_int($workerNum, $taskerNum); + $workerId = random_int($workerNum, $taskerNum - 1); } if (is_string($handler)) { $handler = $this->handle($handler, $params);