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

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-05-03 00:43:38 +08:00
parent efb8f2770a
commit a90e647529
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Async.php
+2 -2
View File
@@ -26,7 +26,7 @@ class Async extends Component
*/ */
public function addAsync(string $name, Task $handler) public function addAsync(string $name, Task $handler)
{ {
$this->_absences[$name] = $handler; $this->_absences[$name] = $handler::class;
} }
@@ -47,7 +47,7 @@ class Async extends Component
} }
/** @var Task $class */ /** @var Task $class */
$class = $this->_absences[$name]; $class = new $this->_absences[$name]();
$class->setParams($params); $class->setParams($params);
$randWorkerId = random_int(0, $server->setting['task_worker_num'] - 1); $randWorkerId = random_int(0, $server->setting['task_worker_num'] - 1);