as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

e

Browse Source
This commit is contained in:
Mr·x
2020-09-11 14:51:40 +08:00
parent 4c144b24c7
commit cb52de44ff
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Queue/Queue.php
+1 -4
View File
@@ -59,12 +59,9 @@ class Queue extends \Snowflake\Process\Process
Timer::tick(50, function () { Timer::tick(50, function () {
$redis = Snowflake::app()->getRedis(); $redis = Snowflake::app()->getRedis();
try { try {
if ($this->shutdown) {
return;
}
$data = $redis->zRevRange(Waiting::QUEUE_WAITING, 0, 20); $data = $redis->zRevRange(Waiting::QUEUE_WAITING, 0, 20);
if (empty($data)) { if (empty($data)) {
Coroutine::sleep(0.05); return;
} else { } else {
Coroutine::create(function ($params) { Coroutine::create(function ($params) {
$this->scheduler($params); $this->scheduler($params);