From 35b91a60046878bb495a835d0d9b615a45e3f729 Mon Sep 17 00:00:00 2001
From: mic <562710164>
Date: Fri, 17 Feb 2023 18:09:26 +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 e44af80..0d9fde6 100644
--- a/tcp/gnetserver.go
+++ b/tcp/gnetserver.go
@@ -68,11 +68,8 @@ func (s *GnetServer) OnShutdown(eng gnet.Engine) {
 	logx.Infof("关闭服务 %s ",
 		fmt.Sprintf("%s://%s", s.network, s.addr))
 	if handler, ok := s.handlers.Load(define.SYS_NET_ENV_SHUTDOWN); ok {
-		_ = s.workerPool.Submit(
-			func() {
-				h := handler.(HandlerFunc)
-				h(nil, nil)
-			})
+		h := handler.(HandlerFunc)
+		h(nil, nil)
 	}
 	s.workerPool.Release()
 }
diff --git a/ws/gnetserver.go b/ws/gnetserver.go
index e675a05..c46fc6b 100644
--- a/ws/gnetserver.go
+++ b/ws/gnetserver.go
@@ -67,11 +67,8 @@ func (s *GnetServer) OnShutdown(eng gnet.Engine) {
 	logx.Infof("关闭服务 %s ",
 		fmt.Sprintf("%s://%s", s.network, s.addr))
 	if handler, ok := s.handlers.Load(define.SYS_NET_ENV_SHUTDOWN); ok {
-		_ = s.workerPool.Submit(
-			func() {
-				h := handler.(HandlerFunc)
-				h(nil, nil)
-			})
+		h := handler.(HandlerFunc)
+		h(nil, nil)
 	}
 	s.workerPool.Release()
 }