From 0666d4c8422d1a80d51d08454f7cc4bc71a1df12 Mon Sep 17 00:00:00 2001 From: "as2252258@163.com" Date: Sat, 20 Mar 2021 03:26:50 +0800 Subject: [PATCH] modify --- System/Process/CrontabProcess.php | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/System/Process/CrontabProcess.php b/System/Process/CrontabProcess.php index 2819161f..cbdec8e5 100644 --- a/System/Process/CrontabProcess.php +++ b/System/Process/CrontabProcess.php @@ -42,17 +42,6 @@ class CrontabProcess extends Process private function waitGroup() - { - $this->waitGroup = new WaitGroup(); - $this->waitGroup->add(); - Coroutine\go(function () { - $this->readByCha(); - }); - $this->waitGroup->wait(-1); - } - - - private function readByCha() { try { $content = $this->channel->pop(-1); @@ -117,14 +106,10 @@ class CrontabProcess extends Process // }; // $timer = $content->getTickTime() * 10; - $this->waitGroup->add(); - var_dump(serialize($content)); Timer::after(3000, function () use ($content) { - $this->waitGroup->add(-1); - $this->application->warning('execute crontab ' . date('Y-m-d H:i:s')); $content->execute($this); });