diff --git a/HttpServer/Events/OnShutdown.php b/HttpServer/Events/OnShutdown.php index 06a91481..b59533b0 100644 --- a/HttpServer/Events/OnShutdown.php +++ b/HttpServer/Events/OnShutdown.php @@ -15,6 +15,7 @@ use Snowflake\Event; use Snowflake\Exception\ComponentException; use Snowflake\Exception\ConfigException; use Snowflake\Snowflake; +use Swoole\Coroutine; use Swoole\Server; use Closure; @@ -32,7 +33,7 @@ class OnShutdown extends Callback */ public function onHandler(Server $server) { - $this->system_mail('server shutdown~'); + Coroutine::create([$this,'system_mail'],'server shutdown~'); $event = Snowflake::app()->getEvent(); if (!$event->exists(Event::SERVER_SHUTDOWN)) { return; diff --git a/HttpServer/Events/OnWorkerError.php b/HttpServer/Events/OnWorkerError.php index e00aeb54..6bf7aa3f 100644 --- a/HttpServer/Events/OnWorkerError.php +++ b/HttpServer/Events/OnWorkerError.php @@ -8,6 +8,7 @@ use Exception; use HttpServer\Abstracts\Callback; use Snowflake\Abstracts\Config; use Snowflake\Exception\ConfigException; +use Swoole\Coroutine; use Swoole\Server; class OnWorkerError extends Callback @@ -27,7 +28,7 @@ class OnWorkerError extends Callback if (!Config::has('email')) { return; } - $this->system_mail(print_r([ + Coroutine::create([$this,'system_mail'],print_r([ '$worker_pid' => $worker_pid, '$worker_id' => $worker_id, '$exit_code' => $exit_code,