lxh/logger
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

🐛ants使用了默认连接池不要release，会变得不幸😢

Browse Source
This commit is contained in:
coward 2024-11-29 16:12:03 +08:00
parent 869dedc580
commit aff875eb11
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
loki.go
View File

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