feat:提交

jyBXCore/entity/logs.go

@@ -39,10 +39,9 @@ func NewSaveLog(name, saveColl string, mgoSaveCacheSize, sPSize, bulkSize, timeA
 
 // SendLogs 往通道发送数据
 func (s *SaveLogs) SendLogs(data map[string]interface{}) {
-	timer := time.NewTicker(time.Duration(s.Timeout) * time.Millisecond)
 	select {
 	case s.MgoSaveCache <- data:
-	case <-timer.C:
+	case <-time.After(time.Duration(s.Timeout)*time.Millisecond):
 		log.Println("缓存通道已满,丢弃：", data)
 		return
 	}