From 166f2db0a054024b9235b8fde2dcd3241b54a716 Mon Sep 17 00:00:00 2001 From: wulin Date: Wed, 22 Nov 2023 14:54:52 +0800 Subject: [PATCH] =?UTF-8?q?BaseSession=E4=BD=BF=E7=94=A8=E5=AE=89=E5=85=A8?= =?UTF-8?q?list?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/qiuguo/iot/data/domain/BaseSession.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java b/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java index b19374c..52c525f 100644 --- a/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java +++ b/iot-common/iot-data/src/main/java/com/qiuguo/iot/data/domain/BaseSession.java @@ -6,6 +6,8 @@ import lombok.Data; import org.springframework.web.reactive.socket.WebSocketMessage; import org.springframework.web.reactive.socket.WebSocketSession; import reactor.core.publisher.FluxSink; + +import java.util.Collections; import java.util.List; import java.util.ArrayList; @@ -82,6 +84,7 @@ public class BaseSession { /** * 临时记录发送给客户端resp + * 语音合成时使用 */ - List respList = new ArrayList<>(10); + List respList = Collections.synchronizedList(new ArrayList<>(10)); }