as2252258/kiri-http-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

改名

Browse Source
This commit is contained in:
向林
2021-12-01 15:18:34 +08:00
parent 44a9a507f6
commit 8ae395e9cd
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Tasker/AsyncTaskExecute.php
+5 -3
View File
@@ -2,12 +2,12 @@
namespace Server\Tasker; namespace Server\Tasker;
use Kiri\Kiri;
use Note\Inject;
use Exception; use Exception;
use Kiri\Abstracts\BaseObject; use Kiri\Abstracts\BaseObject;
use Kiri\Core\HashMap; use Kiri\Core\HashMap;
use Kiri\Di\Container; use Kiri\Di\Container;
use Kiri\Kiri;
use Note\Inject;
use Psr\Container\ContainerInterface; use Psr\Container\ContainerInterface;
use ReflectionException; use ReflectionException;
use Server\Contract\OnTaskInterface; use Server\Contract\OnTaskInterface;
@@ -68,7 +68,9 @@ class AsyncTaskExecute extends BaseObject
$this->server = Kiri::getDi()->get(SwooleServerInterface::class); $this->server = Kiri::getDi()->get(SwooleServerInterface::class);
} }
if ($workerId === null || $workerId <= $this->server->setting['worker_num']) { 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)) { if (is_string($handler)) {
$handler = $this->handle($handler, $params); $handler = $this->handle($handler, $params);