From e2744a54f236e78d09a59f59ef434615bfdafbab Mon Sep 17 00:00:00 2001 From: laodaming <11058467+laudamine@user.noreply.gitee.com> Date: Mon, 21 Aug 2023 11:27:17 +0800 Subject: [PATCH] fix --- server/websocket/internal/logic/ws_render_image_logic.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/server/websocket/internal/logic/ws_render_image_logic.go b/server/websocket/internal/logic/ws_render_image_logic.go index 7e44e43d..db3816aa 100644 --- a/server/websocket/internal/logic/ws_render_image_logic.go +++ b/server/websocket/internal/logic/ws_render_image_logic.go @@ -296,17 +296,15 @@ func (w *wsConnectItem) assembleRenderData(taskId string, info websocket_data.Re func (w *wsConnectItem) operationRenderTask() { for { select { - case <-w.closeChan: //整个链接关闭 + case <-w.closeChan: return - case data := <-w.renderProperty.renderImageTaskCtlChan: //处理任务 + case data := <-w.renderProperty.renderImageTaskCtlChan: switch data.Option { case 0: //删除任务 delete(w.renderProperty.renderImageTask, data.TaskId) case 1: //新增任务 w.renderProperty.renderImageTask[data.TaskId] = data.RenderId } - case <-time.After(time.Second * 3): //三秒阻塞则丢弃 - return } } }