up

core/candle.go

@@ -244,9 +244,8 @@ func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration,
 		Content: cd,
 		Tag:     "sardine.log.candle." + cl.Period,
 	}
-	go func() {
+	err := wg.Process(core)
-		core.WriteLogChan <- &wg
+	fmt.Println("writeLog err:", err)
-	}()
 	core.SaveToSortSet(period, keyName, extt, tsi)
 }
 

core/core.go

@@ -72,15 +72,6 @@ func (rst *RestQueue) Save(cr *Core) {
 	cr.SaveCandle(rst.InstId, rst.Bar, rsp, rst.Duration, rst.WithWs)
 }
 
-func WriteLogProcess(cr *Core) {
-	for {
-		wg := <-cr.WriteLogChan
-		go func(wg *WriteLog) {
-			wg.Process(cr)
-		}(wg)
-	}
-}
-
 func (cr *Core) ShowSysTime() {
 	rsp, _ := cr.RestInvoke("/api/v5/public/time", rest.GET)
 	fmt.Println("serverSystem time:", rsp)

main.go

@@ -231,10 +231,6 @@ func main() {
 	go func() {
 		LoopSaveCandle(&cr)
 	}()
-
-	go func() {
-		core.WriteLogProcess(&cr)
-	}()
 	// 永久阻塞
 	select {}
 }