This commit is contained in:
as2252258@163.com
2021-03-20 03:05:46 +08:00
parent 5ec708d3af
commit 422d40c347
-13
View File
@@ -33,7 +33,6 @@ class CrontabProcess extends Process
*/
public function onHandler(\Swoole\Process $process): void
{
Timer::set(['enable_coroutine' => false]);
while (true) {
try {
$content = $process->read();
@@ -94,24 +93,12 @@ class CrontabProcess extends Process
$content = unserialize($content);
$runTicker = function (Crontab $crontab) {
$this->application->warning('execute crontab ' . date('Y-m-d H:i:s'));
if (!file_exists(APP_PATH . 'runTicker.log')) {
touch(APP_PATH . 'runTicker.log');
}
file_put_contents(APP_PATH . 'runTicker.log', date('Y-m-d H:i:s'), FILE_APPEND);
$crontab->execute($this);
};
$timer = $content->getTickTime() * 10;
if ($content->isLoop()) {
$this->application->warning('loop crontab');
$content->setTimerId(Timer::tick($timer, $runTicker, $content));
} else {
$this->application->warning('after crontab');
$content->setTimerId(Timer::after($timer, $runTicker, $content));
}
$this->names[$content->getName()] = $content;