Commit 0c382ec1 authored by duanruiming's avatar duanruiming

[update] 测试优化线程池运行1

parent 386fdfaf
......@@ -97,6 +97,7 @@ public class SignalStatusTask {
lightsStatusVOS = mapper.convertValue(jsonViewObject.getContent(), new TypeReference<List<LightsStatusVO>>() {});
}
long end = System.currentTimeMillis();
log.info("当前路口编号:{},海康返回灯态时间:{}ms", crossId, (end - start));
RealTimeDataWebSocket webSocket = entry.getValue();
if (!CollectionUtils.isEmpty(lightsStatusVOS)) {
......@@ -126,10 +127,9 @@ public class SignalStatusTask {
});
}
}
commonThreadPoolExecutor.shutdown();
log.info("当前线程数量:{}", Thread.currentThread().activeCount());
} catch (Exception e) {
log.error("实时推送灯态数据失败", e);
}
log.info("当前线程数量:{}", Thread.currentThread().activeCount());
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment