modify
This commit is contained in:
@@ -71,18 +71,13 @@ class CrontabProcess extends Process
|
|||||||
*/
|
*/
|
||||||
private function dispatch(Crontab $value)
|
private function dispatch(Crontab $value)
|
||||||
{
|
{
|
||||||
try {
|
$value->increment()->execute();
|
||||||
$value->increment()->execute();
|
if ($value->getExecuteNumber() < $value->getMaxExecuteNumber()) {
|
||||||
if ($value->getExecuteNumber() < $value->getMaxExecuteNumber()) {
|
$this->addTask($value);
|
||||||
$this->addTask($value);
|
} else if ($value->isLoop()) {
|
||||||
} else if ($value->isLoop()) {
|
$this->addTask($value);
|
||||||
$this->addTask($value);
|
|
||||||
}
|
|
||||||
} catch (\Throwable $exception) {
|
|
||||||
$this->application->error($exception->getMessage());
|
|
||||||
} finally {
|
|
||||||
fire(Event::SYSTEM_RESOURCE_RELEASES);
|
|
||||||
}
|
}
|
||||||
|
fire(Event::SYSTEM_RESOURCE_RELEASES);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user