This commit is contained in:
2023-04-22 02:47:37 +08:00
parent e8c4a729a5
commit 2f6b14f5f7
+4 -1
View File
@@ -79,7 +79,10 @@ class Task implements TaskInterface
} }
if (is_string($handler)) { if (is_string($handler)) {
$server->task(serialize([di($handler), 'handle']), $workerId); $server->task(serialize([di($handler), 'handle']), $workerId);
} else if (is_string($handler[0])) { } else if (is_array($handler)) {
if (is_string($handler[0])) {
$handler[0] = di($handler[0]);
}
$server->task(serialize($handler), $workerId); $server->task(serialize($handler), $workerId);
} else { } else {
$server->task(serialize([$handler, 'handle']), $workerId); $server->task(serialize([$handler, 'handle']), $workerId);