From 0c00cf583c3e024ef13ae60a1d6cd4b82b904f63 Mon Sep 17 00:00:00 2001
From: mic <562710164>
Date: Fri, 17 Feb 2023 18:14:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9A=E4=B9=89=E7=B3=BB?=
 =?UTF-8?q?=E7=BB=9F=E4=BA=8B=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tcp/gnetserver.go | 7 ++-----
 ws/gnetserver.go  | 7 ++-----
 2 files changed, 4 insertions(+), 10 deletions(-)

diff --git a/tcp/gnetserver.go b/tcp/gnetserver.go
index 0d9fde6..b73d272 100644
--- a/tcp/gnetserver.go
+++ b/tcp/gnetserver.go
@@ -101,11 +101,8 @@ func (s *GnetServer) OnClose(c gnet.Conn, err error) (action gnet.Action) {
 	connected := atomic.AddInt32(&s.connected, -1)
 	logx.Infof("在线：%d,最高在线：%d", connected, atomic.LoadInt32(&s.maxConnected))
 	if handler, ok := s.handlers.Load(define.SYS_NET_ENV_CLOSE); ok {
-		_ = s.workerPool.Submit(
-			func() {
-				h := handler.(HandlerFunc)
-				h(c, nil)
-			})
+		h := handler.(HandlerFunc)
+		h(c, nil)
 	}
 	return
 }
diff --git a/ws/gnetserver.go b/ws/gnetserver.go
index c46fc6b..438d90a 100644
--- a/ws/gnetserver.go
+++ b/ws/gnetserver.go
@@ -98,11 +98,8 @@ func (s *GnetServer) OnClose(c gnet.Conn, err error) (action gnet.Action) {
 	connected := atomic.AddInt32(&s.connected, -1)
 	logx.Infof("在线：%d,最高在线：%d", connected, atomic.LoadInt32(&s.maxConnected))
 	if handler, ok := s.handlers.Load(define.SYS_NET_ENV_CLOSE); ok {
-		_ = s.workerPool.Submit(
-			func() {
-				h := handler.(HandlerFunc)
-				h(c, nil)
-			})
+		h := handler.(HandlerFunc)
+		h(c, nil)
 	}
 	return
 }