This commit is contained in:
2021-03-01 16:20:13 +08:00
parent eb27d1880e
commit a6ff562b0a
+1 -5
View File
@@ -96,11 +96,7 @@ class OnWorkerStart extends Callback
*/
public function onSignal(Server $server, $worker_id): mixed
{
$receive = Coroutine::waitSignal($this->signal, -1);
if ($server->getWorkerStatus($worker_id) == SWOOLE_WORKER_IDLE) {
return $server->stop($worker_id);
}
while ($receive === true) {
while (Coroutine::waitSignal($this->signal)) {
if (!Snowflake::app()->isRun()) {
return $server->stop($worker_id);
}