diff --git a/HttpServer/Events/OnTask.php b/HttpServer/Events/OnTask.php index 25dd67dd..07ef8f07 100644 --- a/HttpServer/Events/OnTask.php +++ b/HttpServer/Events/OnTask.php @@ -137,7 +137,6 @@ class OnTask extends Callback if (empty($serialize = swoole_unserialize($data))) { return null; } - $serialize = array_shift($serialize); if (!($serialize instanceof ITask)) { return null; } diff --git a/System/Async.php b/System/Async.php index 380140bb..b95c5d6c 100644 --- a/System/Async.php +++ b/System/Async.php @@ -52,7 +52,7 @@ class Async extends Component $randWorkerId = random_int(0, $server->setting['task_worker_num'] - 1); - $server->task(swoole_serialize([$class, 'onHandler']), $randWorkerId); + $server->task(serialize($class), $randWorkerId); } }