modify
This commit is contained in:
@@ -6,6 +6,7 @@ namespace Snowflake\Process;
|
|||||||
|
|
||||||
use Snowflake\Crontab;
|
use Snowflake\Crontab;
|
||||||
use Snowflake\Abstracts\Crontab as ACrontab;
|
use Snowflake\Abstracts\Crontab as ACrontab;
|
||||||
|
use Snowflake\Event;
|
||||||
use Snowflake\Snowflake;
|
use Snowflake\Snowflake;
|
||||||
use Swoole\Coroutine;
|
use Swoole\Coroutine;
|
||||||
use Swoole\Coroutine\WaitGroup;
|
use Swoole\Coroutine\WaitGroup;
|
||||||
@@ -53,6 +54,7 @@ class CrontabProcess extends Process
|
|||||||
$this->dispatch($value);
|
$this->dispatch($value);
|
||||||
}, $crontab, $startTime);
|
}, $crontab, $startTime);
|
||||||
}
|
}
|
||||||
|
$redis->release();
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -73,6 +75,8 @@ class CrontabProcess extends Process
|
|||||||
}
|
}
|
||||||
} catch (\Throwable $exception) {
|
} catch (\Throwable $exception) {
|
||||||
$this->application->error($exception->getMessage());
|
$this->application->error($exception->getMessage());
|
||||||
|
} finally {
|
||||||
|
fire(Event::SYSTEM_RESOURCE_RELEASES);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user