fixed 无法结束的bug 2022-10-08

Author: hktalent

config/scan4all_db.db

@@ -102,11 +102,9 @@ func (e *Engine) DoEvent(ed *models.EventData) {
 
 func (x1 *Engine) Running() {
 	// 异步启动一个线程处理检测，避免
-	util.Wg.Add(1)
 	go func() {
 		defer func() {
 			x1.Close()
-			util.Wg.Done()
 		}()
 		//nMax := 120 // 等xxx秒都没有消息进入就退出
 		//nCnt := 0

engine/engineImp.go

@@ -6,7 +6,6 @@ import (
 	"embed"
 	"encoding/json"
 	"fmt"
-	"github.com/fsnotify/fsnotify"
 	"github.com/karlseguin/ccache"
 	"github.com/spf13/viper"
 	"io/fs"
@@ -227,12 +226,12 @@ func LoadCoinfig(config *viper.Viper) {
 		return
 	}
 	config.Unmarshal(&mData)
-	config.OnConfigChange(func(e fsnotify.Event) {
-		log.Println("Config file changed, now reLoad it: ", e.Name)
-		LoadCoinfig(config)
-	})
+	//config.OnConfigChange(func(e fsnotify.Event) {
+	//	log.Println("Config file changed, now reLoad it: ", e.Name)
+	//	LoadCoinfig(config)
+	//})
 	// 避免 hold
-	go config.WatchConfig()
+	//go config.WatchConfig()
 }
 
 // 初始化配置文件信息，这个必须先执行