diff --git a/Tasker/AsyncTask.php b/Tasker/AsyncTask.php index d093aa0..698ef9d 100644 --- a/Tasker/AsyncTask.php +++ b/Tasker/AsyncTask.php @@ -36,8 +36,7 @@ class AsyncTask public function execute(OnTaskInterface|string $handler, array $params = [], int $workerId = null) { if ($workerId === null || $workerId <= $this->server->setting['worker_num']) { - $workerId = random_int($this->server->setting['worker_num'] + 1, - $this->server->setting['worker_num'] + 1 + $this->server->setting['task_worker_num']); + $workerId = random_int($this->server->setting['worker_num'] + 1, $this->server->setting['task_worker_num']); } if (is_string($handler)) { $handler = $this->handle($handler, $params);