YuanHong
/
YHEchoPackage
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 22 Wiki Activity

添加定义系统事件

master v0.0.19
mic 2023-02-17 18:09:26 +08:00
parent 09172d231d
commit 35b91a6004
2 changed files with 4 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tcp/gnetserver.go
View File

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

7
ws/gnetserver.go
View File

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