//计数器 并发的个数 CountDownLatch dataCount = new CountDownLatch(10); for (int i = 0;i < 10;i++){
//你要执行的方法 ThreadPoolManager.threads.execute(()->{ Map<String, MonitorLogView> map = getRequestAndOrderData(apiMonitorParam); if (MapUtils.isNotEmpty(map)){ mapData.put("request", map.get("request")); mapData.put("order", map.get("order")); } dataCount.countDown();//每之行完一次后计数器减1 }); }
//每一个线程执行完成之后都会在这里等待 等待所有的执行完毕
try {
dataCount.await(); } catch (InterruptedException e) { log.error("error", e); }