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() }