HDK/hyperf-admin
1
0
Fork 0
mirror of http://124.126.16.154:8888/singularity/hyperf-admin.git synced 2026-01-15 05:55:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

perf: optmize cront-center

Browse Source
This commit is contained in:
daodao97
2020-10-24 15:52:52 +08:00
parent e234ba6d60
commit 98e088ecd3
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/cron-center/src/CrontabDispatcherProcess.php
View File

@@ -1,6 +1,7 @@
<?php
namespace HyperfAdmin\CronCenter;
use Hyperf\Contract\ConfigInterface;
use Hyperf\Crontab\Crontab;
use Hyperf\Crontab\Event\CrontabDispatcherStarted;
use Hyperf\Crontab\Parser;
@@ -27,6 +28,10 @@ class CrontabDispatcherProcess extends ProcessCrontabDispatcherProcess
*/
public $cron_manager;
public $name = 'cron-center-dispatcher';
public $config;
public function __construct(ContainerInterface $container)
{
parent::__construct($container);
@@ -35,13 +40,16 @@ class CrontabDispatcherProcess extends ProcessCrontabDispatcherProcess
$this->strategy = $container->get(StrategyInterface::class);
$this->parser = make(Parser::class);
$this->cron_manager = make(CronManager::class);
$this->config = $container->get(ConfigInterface::class);
}
public function isEnable($server): bool
{
return $this->config->get('cron_center.enable', false);
}
public function handle(): void
{
if (!config('cron_center.enable', false)) {
return;
}
$this->event->dispatch(new CrontabDispatcherStarted());
while (true) {
$this->cron_manager->createOrUpdateNode();