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);