From cb52de44ffd91cb62055c6a055528a3b61f61ff2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mr=C2=B7x?= Date: Fri, 11 Sep 2020 14:51:40 +0800 Subject: [PATCH] e --- Queue/Queue.php | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/Queue/Queue.php b/Queue/Queue.php index f54bbd4b..efab2ffc 100644 --- a/Queue/Queue.php +++ b/Queue/Queue.php @@ -59,12 +59,9 @@ class Queue extends \Snowflake\Process\Process Timer::tick(50, function () { $redis = Snowflake::app()->getRedis(); try { - if ($this->shutdown) { - return; - } $data = $redis->zRevRange(Waiting::QUEUE_WAITING, 0, 20); if (empty($data)) { - Coroutine::sleep(0.05); + return; } else { Coroutine::create(function ($params) { $this->scheduler($params);