loki.go

@@ -75,7 +75,6 @@ func (c lokiWriter) Write(p []byte) (int, error) {
 	label["level"] = model.LabelValue(li.Level)
 	label["caller"] = model.LabelValue(li.Caller)
 
-	// 异步推送消息到服务器
 	_ = ants.Submit(func() {
 		t, e := time.ParseInLocation("2006-01-02 15:04:05.000", li.Ts, time.Local)
 		if e != nil {
@@ -86,8 +85,6 @@ func (c lokiWriter) Write(p []byte) (int, error) {
 		}
 	})
 
-	defer ants.Release()
-
 	return 0, nil
 }