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:46:56 +08:00
parent 7991f8f866
commit 9433d631a9
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Queue/Queue.php
+2 -4
View File
@@ -53,12 +53,10 @@ class Queue extends \Snowflake\Process\Process
/** /**
* @param Process $process * @param Process $process
* @throws ComponentException
* @throws ConfigException
*/ */
public function onHandler(Process $process) public function onHandler(Process $process)
{ {
do { Timer::tick(50, function () {
$redis = Snowflake::app()->getRedis(); $redis = Snowflake::app()->getRedis();
try { try {
if ($this->shutdown) { if ($this->shutdown) {
@@ -75,7 +73,7 @@ class Queue extends \Snowflake\Process\Process
} finally { } finally {
$redis->release(); $redis->release();
} }
} while (true); });
} }