diff --git a/src/Dispatcher.php b/src/Dispatcher.php index 39cc997..584c05b 100644 --- a/src/Dispatcher.php +++ b/src/Dispatcher.php @@ -669,13 +669,6 @@ private function informWorkersQuit() } while (($now - $startInformTime) < $this->shutdownTimeoutSec); } - private function waitChildren() - { - while (($pid = pcntl_wait($status, WNOHANG)) > 0) { - $this->clearWorker($this->idMap[$pid] ?? '', $pid); - } - } - private function cacheMessage(Message $msg) { $this->cachedMessages->push($msg);