优化定时器

farseer-go · Mar 23, 2024 · 4b39eb5 · 4b39eb5
1 parent 1d0689b
commit 4b39eb5
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/flog/fileProvider.go b/flog/fileProvider.go
@@ -69,7 +69,8 @@ func (r *fileLoggerPersistent) Log(LogLevel eumLogLevel.Enum, log *LogData, exce
 
 // 将缓冲区的日志，每隔1秒，写入文件
 func (r *fileLoggerPersistent) writeFile() {
-	for range time.NewTicker(time.Second * time.Duration(r.config.RefreshInterval)).C {
+	ticker := time.NewTicker(time.Second * time.Duration(r.config.RefreshInterval))
+	for range ticker.C {
 		// 组装要写入的日志内容
 		var logs []string
 		for len(r.logsBuffer) > 0 {

diff --git a/flog/fopsProvider.go b/flog/fopsProvider.go
@@ -53,7 +53,8 @@ func (r *fopsLoggerPersistent) Log(LogLevel eumLogLevel.Enum, log *LogData, exce
 
 // 开启上传
 func (r *fopsLoggerPersistent) enableUpload() {
-	for range time.NewTicker(3 * time.Second).C {
+	ticker := time.NewTicker(5 * time.Second)
+	for range ticker.C {
 		var lst []*LogData
 		// 当队列中有数据 且 取出的数量<1000时，则继续取出
 		for len(r.queue) > 0 && len(lst) < 1000 {

diff --git a/fops/registerApp.go b/fops/registerApp.go
@@ -45,7 +45,7 @@ type RegisterAppRequest struct {
 // 每隔3秒，上传当前应用信息
 func register() {
 	if core.AppName == "fops" {
-		<-time.NewTicker(3 * time.Second).C
+		time.Sleep(5 * time.Second)
 	}
 	registerAppRequest := RegisterAppRequest{StartupAt: core.StartupAt, AppName: core.AppName, HostName: core.HostName, AppId: core.AppId, AppIp: core.AppIp, ProcessId: core.ProcessId}
 	for {
@@ -66,14 +66,14 @@ func register() {
 			apiRsp := core.NewApiResponseByReader[any](rsp.Body)
 			if apiRsp.StatusCode != 200 {
 				flog.Warningf("注册应用信息到FOPS失败（%v）%s", rsp.StatusCode, apiRsp.StatusMessage)
-				<-time.NewTicker(20 * time.Second).C
+				time.Sleep(20 * time.Second)
 				continue
 			}
 		} else {
 			flog.Warningf("注册应用信息到FOPS失败：%s", err.Error())
-			<-time.NewTicker(20 * time.Second).C
+			time.Sleep(20 * time.Second)
 			continue
 		}
-		<-time.NewTicker(20 * time.Second).C
+		time.Sleep(20 * time.Second)
 	}
 }