From 49f4e9d01230e73361aaca71609c659fdf250c7c Mon Sep 17 00:00:00 2001 From: steden <1470804@qq.com> Date: Wed, 18 Sep 2024 18:31:29 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E8=AF=95=E7=8A=B6=E6=80=81=E4=B8=8B?= =?UTF-8?q?=EF=BC=8C=E4=B8=8D=E7=94=A8=E5=88=A4=E6=96=AD=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E7=AB=AF=E7=9A=84=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- module.go | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/module.go b/module.go index 8c0f379..030ba87 100644 --- a/module.go +++ b/module.go @@ -16,6 +16,15 @@ func (module Module) DependsModule() []modules.FarseerModule { } func (module Module) PreInitialize() { + // 配置时间轮 + timingWheel.Start() + + // 调试状态下,不开启与调度中心的通信 + if configure.GetBool("FSchedule.Debug.Enable") { + flog.Warning("FSchedule当前为调试状态,将模拟调用任务") + return + } + // 服务端配置 defaultServer = serverVO{ Address: configure.GetSlice("FSchedule.Server.Address"), @@ -26,16 +35,10 @@ func (module Module) PreInitialize() { panic("调度中心的地址[FSchedule.Server.Address]未配置") } - // 客户端配置 - timingWheel.Start() } func (module Module) PostInitialize() { - // 调试状态下,不开启与调度中心的通信 - if configure.GetBool("FSchedule.Debug.Enable") { - flog.Warning("FSchedule当前为调试状态,将模拟调用任务") - return - } + } func (module Module) Shutdown() {