modify
This commit is contained in:
+2
-2
@@ -188,10 +188,10 @@ class Crontab extends BaseObject
|
|||||||
public function execute(): void
|
public function execute(): void
|
||||||
{
|
{
|
||||||
try {
|
try {
|
||||||
|
var_dump('execute');
|
||||||
call_user_func($this->handler, $this->params);
|
call_user_func($this->handler, $this->params);
|
||||||
$this->execute_number += 1;
|
$this->execute_number += 1;
|
||||||
|
if ($this->execute_number >= $this->max_execute_number) {
|
||||||
if ($this->execute_number < $this->max_execute_number) {
|
|
||||||
$this->clearTimer();
|
$this->clearTimer();
|
||||||
}
|
}
|
||||||
} catch (\Throwable $throwable) {
|
} catch (\Throwable $throwable) {
|
||||||
|
|||||||
@@ -78,6 +78,7 @@ class CrontabProcess extends Process
|
|||||||
*/
|
*/
|
||||||
private function jobDelivery($content)
|
private function jobDelivery($content)
|
||||||
{
|
{
|
||||||
|
/** @var Crontab $content */
|
||||||
$content = unserialize($content);
|
$content = unserialize($content);
|
||||||
$this->names[$content->getName()] = $content;
|
$this->names[$content->getName()] = $content;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user