as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-02-27 04:52:20 +08:00
parent d59ce414d9
commit 64ec39976e
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
HttpServer/Events/OnWorkerStart.php
+5 -3
View File
@@ -4,6 +4,7 @@ declare(strict_types=1);
namespace HttpServer\Events; namespace HttpServer\Events;
use co;
use Exception; use Exception;
use HttpServer\Abstracts\Callback; use HttpServer\Abstracts\Callback;
use Snowflake\Abstracts\Config; use Snowflake\Abstracts\Config;
@@ -71,16 +72,17 @@ class OnWorkerStart extends Callback
Coroutine\go(function (Server $server, $worker_id) { Coroutine\go(function (Server $server, $worker_id) {
$sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1); $sigkill = Coroutine::waitSignal(SIGTERM | SIGKILL | SIGUSR2 | SIGUSR1);
if ($sigkill !== false) { if ($sigkill !== false) {
return Process::kill($server->worker_pid,0); return $server->stop();
} }
do { do {
$number = Coroutine::stats()['coroutine_num']; $number = Co::stats()['coroutine_num'];
var_dump($number);
if ($number === 0) { if ($number === 0) {
break; break;
} }
Coroutine::sleep(0.01); Coroutine::sleep(0.01);
} while (true); } while (true);
return Process::kill($server->worker_pid,0); return $server->stop();
}, $server, $worker_id); }, $server, $worker_id);
} }