|
@@ -26,14 +26,12 @@ class queueControl extends BaseCronControl
|
|
|
$queues = $worker->scan();
|
|
|
|
|
|
while (true) {
|
|
|
-
|
|
|
pcntl_signal_dispatch();
|
|
|
|
|
|
if ($this->_stop) {
|
|
|
exit;
|
|
|
}
|
|
|
-
|
|
|
- $content = $worker->pop($queues,3);
|
|
|
+ $content = $worker->pop($queues,1);
|
|
|
|
|
|
if (is_array($content)) {
|
|
|
$method = key($content);
|
|
@@ -48,7 +46,6 @@ class queueControl extends BaseCronControl
|
|
|
$model = Model();
|
|
|
$model->checkActive();
|
|
|
unset($model);
|
|
|
-
|
|
|
}
|
|
|
}
|
|
|
}
|