fix
This commit is contained in:
parent
feae3ada33
commit
e2744a54f2
|
@ -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
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue
Block a user