This commit is contained in:
laodaming 2023-07-26 16:27:24 +08:00
parent e25cc97ea0
commit 7dc9760d94

View File

@ -4,7 +4,6 @@ import (
"encoding/json"
"fusenapi/server/websocket/internal/types"
"github.com/zeromicro/go-zero/core/logx"
"time"
)
// 渲染请求数据处理发送云渲染服务处理
@ -15,14 +14,11 @@ func (w *wsConnectItem) SendToCloudRender(data []byte) {
return
}
logx.Info("收到请求云渲染图片数据:", renderImageData)
timer := time.NewTimer(time.Second * 10)
//把需要渲染的图片任务加进去
for _, v := range renderImageData {
select {
case <-w.closeChan: //连接关闭了
return
case <-timer.C: //10秒超时了
return
default:
//加入渲染任务
key := w.getRenderImageMapKey(v.ProductId, v.SizeId, v.TemplateId)