From 0f1adffdd50b71f71028dfd9dfcd4da66d1921f6 Mon Sep 17 00:00:00 2001 From: xinian Date: Tue, 24 Feb 2026 03:51:25 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E5=B0=86=E4=BA=8B=E4=BB=B6?= =?UTF-8?q?=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91=E4=BB=8E=E5=B7=A5=E4=BD=9C?= =?UTF-8?q?=E6=B1=A0=E6=8F=90=E4=BA=A4=E6=94=B9=E4=B8=BA=E7=9B=B4=E6=8E=A5?= =?UTF-8?q?=E8=B0=83=E7=94=A8OnEvent?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- common/socket/ServerEvent.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/common/socket/ServerEvent.go b/common/socket/ServerEvent.go index 5874a399..98333666 100644 --- a/common/socket/ServerEvent.go +++ b/common/socket/ServerEvent.go @@ -281,10 +281,10 @@ func (s *Server) onevent(c gnet.Conn, v []byte) { } else { header.Data = nil // 避免空切片分配 } - - s.workerPool.Submit(func() { - t.LF.Producer().Write(header) - }) + t.OnEvent(header) + // s.workerPool.Submit(func() { + // t.LF.Producer().Write(header) + // }) } }