改名
This commit is contained in:
@@ -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);
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -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);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -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));
|
||||
}
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user