Commit bd21d0e3910b50a8e6cd658364fe198c5a8e6015

Authored by 648540858
1 parent 36170df3

优化目录获取并法能力

src/main/java/com/genersoft/iot/vmp/gb28181/session/CatalogDataCatch.java
@@ -30,7 +30,7 @@ public class CatalogDataCatch { @@ -30,7 +30,7 @@ public class CatalogDataCatch {
30 CatalogData catalogData = data.get(device.getDeviceId()); 30 CatalogData catalogData = data.get(device.getDeviceId());
31 if (catalogData == null || catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end)) { 31 if (catalogData == null || catalogData.getStatus().equals(CatalogData.CatalogDataStatus.end)) {
32 catalogData = new CatalogData(); 32 catalogData = new CatalogData();
33 - catalogData.setChannelList(new ArrayList<>()); 33 + catalogData.setChannelList(Collections.synchronizedList(new ArrayList<>()));
34 catalogData.setDevice(device); 34 catalogData.setDevice(device);
35 catalogData.setSn(sn); 35 catalogData.setSn(sn);
36 catalogData.setStatus(CatalogData.CatalogDataStatus.ready); 36 catalogData.setStatus(CatalogData.CatalogDataStatus.ready);
@@ -46,7 +46,7 @@ public class CatalogDataCatch { @@ -46,7 +46,7 @@ public class CatalogDataCatch {
46 catalogData.setSn(sn); 46 catalogData.setSn(sn);
47 catalogData.setTotal(total); 47 catalogData.setTotal(total);
48 catalogData.setDevice(device); 48 catalogData.setDevice(device);
49 - catalogData.setChannelList(new ArrayList<>()); 49 + catalogData.setChannelList(Collections.synchronizedList(new ArrayList<>()));
50 catalogData.setStatus(CatalogData.CatalogDataStatus.runIng); 50 catalogData.setStatus(CatalogData.CatalogDataStatus.runIng);
51 catalogData.setLastTime(new Date(System.currentTimeMillis())); 51 catalogData.setLastTime(new Date(System.currentTimeMillis()));
52 data.put(deviceId, catalogData); 52 data.put(deviceId, catalogData);