This commit is contained in:
as2252258@163.com
2021-02-28 17:49:31 +08:00
parent f05ff38bc4
commit 8a557acb2e
+6 -3
View File
@@ -92,14 +92,17 @@ class OnWorkerStart extends Callback
public function onSignal($server, $worker_id) public function onSignal($server, $worker_id)
{ {
Coroutine::create(function ($server, $worker_id) { Coroutine::create(function ($server, $worker_id) {
while (true) {
$ret = Coroutine::waitSignal($this->signal, -1); $ret = Coroutine::waitSignal($this->signal, -1);
var_dump($ret);
if ($ret) { if ($ret) {
while (Snowflake::app()->isRun()) { if (!Snowflake::app()->isRun()) {
var_dump(Snowflake::app()->isRun()); break;
}
sleep(1); sleep(1);
} }
}
$server->stop($worker_id); $server->stop($worker_id);
}
}, $server, $worker_id); }, $server, $worker_id);
} }