线城池实现并发

//计数器  并发的个数
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);
}

猜你喜欢

转载自blog.csdn.net/yueloveme/article/details/80887351