From 8ae395e9cd202513bb9374f1f7412d589e614f38 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Wed, 1 Dec 2021 15:18:34 +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 | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/Tasker/AsyncTaskExecute.php b/Tasker/AsyncTaskExecute.php
index 899860f..c37fed1 100644
--- a/Tasker/AsyncTaskExecute.php
+++ b/Tasker/AsyncTaskExecute.php
@@ -2,12 +2,12 @@
 
 namespace Server\Tasker;
 
-use Kiri\Kiri;
-use Note\Inject;
 use Exception;
 use Kiri\Abstracts\BaseObject;
 use Kiri\Core\HashMap;
 use Kiri\Di\Container;
+use Kiri\Kiri;
+use Note\Inject;
 use Psr\Container\ContainerInterface;
 use ReflectionException;
 use Server\Contract\OnTaskInterface;
@@ -68,7 +68,9 @@ class AsyncTaskExecute extends BaseObject
 			$this->server = Kiri::getDi()->get(SwooleServerInterface::class);
 		}
 		if ($workerId === null || $workerId <= $this->server->setting['worker_num']) {
-			$workerId = random_int($this->server->setting['worker_num'] + 1, $this->server->setting['task_worker_num']);
+			$workerNum = $this->server->setting['worker_num'] + 1;
+			$taskerNum = $workerNum + $this->server->setting['task_worker_num'];
+			$workerId = random_int($workerNum, $taskerNum);
 		}
 		if (is_string($handler)) {
 			$handler = $this->handle($handler, $params);