优化node状态

This commit is contained in:
boyce
2024-06-20 09:10:18 +08:00
parent f5e86fee02
commit 0a92f48d0b

View File

@@ -29,6 +29,7 @@ var preSetupTemplateService []func()service.IService
var profilerInterval time.Duration var profilerInterval time.Duration
var bValid bool var bValid bool
var configDir = "./config/" var configDir = "./config/"
var NodeIsRun = false
const( const(
SingleStop syscall.Signal = 10 SingleStop syscall.Signal = 10
@@ -354,13 +355,14 @@ func startNode(args interface{}) error {
cluster.GetCluster().Start() cluster.GetCluster().Start()
//6.监听程序退出信号&性能报告 //6.监听程序退出信号&性能报告
bRun := true
var pProfilerTicker *time.Ticker = &time.Ticker{} var pProfilerTicker *time.Ticker = &time.Ticker{}
if profilerInterval > 0 { if profilerInterval > 0 {
pProfilerTicker = time.NewTicker(profilerInterval) pProfilerTicker = time.NewTicker(profilerInterval)
} }
for bRun { NodeIsRun = true
for NodeIsRun {
select { select {
case s := <-sig: case s := <-sig:
signal := s.(syscall.Signal) signal := s.(syscall.Signal)
@@ -368,7 +370,7 @@ func startNode(args interface{}) error {
log.Info("receipt retire signal.") log.Info("receipt retire signal.")
notifyAllServiceRetire() notifyAllServiceRetire()
}else { }else {
bRun = false NodeIsRun = false
log.Info("receipt stop signal.") log.Info("receipt stop signal.")
} }
case <-pProfilerTicker.C: case <-pProfilerTicker.C: