From 631c66874f050dd7a124b99fbb9b6d691eb2d4d4 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sat, 20 Mar 2021 03:35:44 +0800 Subject: [PATCH] modify --- System/Process/CrontabProcess.php | 20 +++++++++++++++++--- 1 file changed, 17 insertions(+), 3 deletions(-) diff --git a/System/Process/CrontabProcess.php b/System/Process/CrontabProcess.php index 61deccdd..eaa6a5fd 100644 --- a/System/Process/CrontabProcess.php +++ b/System/Process/CrontabProcess.php @@ -35,12 +35,26 @@ class CrontabProcess extends Process Coroutine\go(function () { $this->waitGroup(); }); - while (true) { - $this->channel->push($process->read()); - } + $this->readByWorker($process); } + /** + * @param $process + */ + private function readByWorker($process) + { + $this->channel->push($process->read()); + + Coroutine::sleep(0.01); + + $this->readByWorker($process); + } + + + /** + * @throws \Exception + */ private function waitGroup() { try {