as2252258/kiri-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

modify

Browse Source
This commit is contained in:
as2252258@163.com
2021-03-20 03:39:11 +08:00
parent 28e8e09dee
commit de05d5099c
1 changed files with 10 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
System/Process/CrontabProcess.php
+10 -27
View File
@@ -116,34 +116,17 @@ class CrontabProcess extends Process
{
/** @var Crontab $content */
$content = unserialize($content);
// $runTicker = function () use ($content) {
// $this->application->warning('execute crontab ' . date('Y-m-d H:i:s'));
// $content->execute($this);
// };
// $timer = $content->getTickTime() * 10;
var_dump(serialize($content));
Timer::after(3000, function () use ($content) {
$runTicker = function () use ($content) {
$this->application->warning('execute crontab ' . date('Y-m-d H:i:s'));
// $content->execute($this);
});
var_dump(Timer::stats());
// if ($content->isLoop()) {
// $content->setTimerId(Timer::tick($timer, function () use ($content) {
// $this->application->warning('execute crontab ' . date('Y-m-d H:i:s'));
// $content->execute($this);
// }));
// } else {
// $content->setTimerId(Timer::after($timer, function () use ($content) {
// $this->application->warning('execute crontab ' . date('Y-m-d H:i:s'));
// $content->execute($this);
// }));
// }
// $this->names[$content->getName()] = $content;
$content->execute($this);
};
$timer = $content->getTickTime() * 10;
if ($content->isLoop()) {
$content->setTimerId(Timer::tick($timer, $runTicker));
} else {
$content->setTimerId(Timer::after($timer, $runTicker));
}
$this->names[$content->getName()] = $content;
}