|
@@ -241,7 +241,7 @@ public class ChannelAnalyseServiceImpl implements ChannelAnalyseService {
|
|
|
List<String> collect = queryWd.stream().map(item -> {
|
|
|
return RedisContant.WD_TAG + "_" + item.getWdId();
|
|
|
}).collect(Collectors.toList());
|
|
|
- queryWd.clear();
|
|
|
+ queryWd = null;
|
|
|
|
|
|
//切割网点 并 统计分析标签
|
|
|
ConcurrentHashMap<String, Integer> concurrentHashMap = new ConcurrentHashMap<>();
|
|
@@ -265,7 +265,7 @@ public class ChannelAnalyseServiceImpl implements ChannelAnalyseService {
|
|
|
|
|
|
//3.统计
|
|
|
CompletableFuture.allOf(splitList.toArray(new CompletableFuture[splitList.size()])).join();
|
|
|
- splitList.clear();
|
|
|
+ splitList = null;
|
|
|
|
|
|
//4.封装统计值
|
|
|
HashMap<String, Object> result = new HashMap<>();
|
|
@@ -325,6 +325,7 @@ public class ChannelAnalyseServiceImpl implements ChannelAnalyseService {
|
|
|
}
|
|
|
total++;
|
|
|
}
|
|
|
+ wdTagList = null;
|
|
|
concurrentHashMap.put("total",concurrentHashMap.get("total")+total);
|
|
|
}
|
|
|
|