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 }