refactor: 将事件处理逻辑从工作池提交改为直接调用OnEvent
Some checks failed
ci/woodpecker/push/my-first-workflow Pipeline failed
Some checks failed
ci/woodpecker/push/my-first-workflow Pipeline failed
This commit is contained in:
@@ -281,10 +281,10 @@ func (s *Server) onevent(c gnet.Conn, v []byte) {
|
|||||||
} else {
|
} else {
|
||||||
header.Data = nil // 避免空切片分配
|
header.Data = nil // 避免空切片分配
|
||||||
}
|
}
|
||||||
|
t.OnEvent(header)
|
||||||
s.workerPool.Submit(func() {
|
// s.workerPool.Submit(func() {
|
||||||
t.LF.Producer().Write(header)
|
// t.LF.Producer().Write(header)
|
||||||
})
|
// })
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user