fusen/fusenapi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

11

Browse Source
This commit is contained in:
laodaming 2023-10-07 15:15:16 +08:00
parent 7d3f614356
commit 9dbcf33cb9
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/websocket/internal/logic/ws_render_image.go
View File

@ -92,8 +92,9 @@ func (w *wsConnectItem) consumeRenderImageData() {
logx.Error("func renderImage main panic:", err) logx.Error("func renderImage main panic:", err)
} }
}() }()
tChan := make(chan struct{}, 1) //临时chan用select io多路复用去判断携程退出
defer close(tChan) tmpChan := make(chan struct{}, 1)
defer close(tmpChan)
defer func() { defer func() {
<-limitChan <-limitChan
}() }()
@ -106,7 +107,7 @@ func (w *wsConnectItem) consumeRenderImageData() {
select { select {
case <-w.extendRenderProperty.renderCtx.Done(): case <-w.extendRenderProperty.renderCtx.Done():
panic("=========渲染取消旧的上下文=======") panic("=========渲染取消旧的上下文=======")
case <-tChan: case <-tmpChan:
return return
} }
}() }()