This commit is contained in:
2021-03-01 18:14:00 +08:00
parent ffe81925eb
commit 603d578128
+7 -4
View File
@@ -8,6 +8,7 @@ namespace HttpServer\Events;
use HttpServer\Abstracts\Callback; use HttpServer\Abstracts\Callback;
use HttpServer\IInterface\Task; use HttpServer\IInterface\Task;
use HttpServer\IInterface\Task as ITask; use HttpServer\IInterface\Task as ITask;
use Snowflake\Abstracts\Config;
use Snowflake\Event; use Snowflake\Event;
use Snowflake\Snowflake; use Snowflake\Snowflake;
use Swoole\Coroutine; use Swoole\Coroutine;
@@ -28,11 +29,13 @@ class OnTask extends Callback
*/ */
public function onHandler() public function onHandler()
{ {
$parameter = func_get_args(); $setting = Snowflake::app()->getSwoole();
if (func_num_args() < 4) {
$this->onContinueTask(...$parameter); $isCoroutineTask = $setting->setting['task_enable_coroutine'] ?? false;
if ($isCoroutineTask === true) {
call_user_func([$this, 'onContinueTask'], ...func_get_args());
} else { } else {
$this->onTask(...$parameter); call_user_func([$this, 'onTask'], ...func_get_args());
} }
} }