diff --git a/kiri-engine/Abstracts/BaseApplication.php b/kiri-engine/Abstracts/BaseApplication.php index 2d5e8752..f55e28d8 100644 --- a/kiri-engine/Abstracts/BaseApplication.php +++ b/kiri-engine/Abstracts/BaseApplication.php @@ -29,6 +29,7 @@ use Kiri\Kiri; use ReflectionException; use Server\ServerManager; use Server\Contract\OnTaskInterface; +use Server\Tasker\AsyncTaskExecute; use Swoole\Table; /** @@ -210,7 +211,7 @@ abstract class BaseApplication extends Component */ public function task(OnTaskInterface $execute): void { - di(ServerManager::class)->task($execute); + di(AsyncTaskExecute::class)->execute($execute); } diff --git a/kiri-engine/Async.php b/kiri-engine/Async.php index c11188b3..3da691c9 100644 --- a/kiri-engine/Async.php +++ b/kiri-engine/Async.php @@ -7,6 +7,7 @@ namespace Kiri; use Exception; use Kiri\Abstracts\Component; use Server\ServerManager; +use Server\Tasker\AsyncTaskExecute; /** * Class Async @@ -36,8 +37,8 @@ class Async extends Component */ public function dispatch(string $name, array $params = []) { - $context = di(ServerManager::class); - $context->task(static::$_absences[$name], $params); + $context = di(AsyncTaskExecute::class); + $context->execute(static::$_absences[$name], $params); } } diff --git a/kiri-engine/Kiri.php b/kiri-engine/Kiri.php index ff871c77..32d39dcc 100644 --- a/kiri-engine/Kiri.php +++ b/kiri-engine/Kiri.php @@ -16,6 +16,7 @@ use Kiri\Di\Container; use Psr\Container\ContainerInterface; use ReflectionException; use Server\ServerManager; +use Server\Tasker\AsyncTaskExecute; use Swoole\Coroutine; use Swoole\Process; use Swoole\WebSocket\Server; @@ -457,8 +458,8 @@ class Kiri */ public static function async(string $class, array $params = []) { - $manager = di(ServerManager::class); - $manager->task(new $class(...$params)); + $manager = di(AsyncTaskExecute::class); + $manager->execute(new $class(...$params)); }