// 创建2个线程的线程池
Executor executor = Executors.newFixedThreadPool(2);
while(存在未对账订单){
// 计数器初始化为2
CountDownLatch latch = new CountDownLatch(2);
// 查询未对账订单
executor.execute(()->{
pos = getPOrders();
latch.countDown();
});
// 查询派送单
executor.execute(()->{
dos = getDOrders();
latch.countDown();
});
// 等待两个查询操作结束
latch.await();
// 执⾏对账操作
diff = check(pos, dos);
// 差异写⼊差异库
save(diff);
}
计数器
CountDownLatch： 一个线程等待多个线程。
//定义一个初始值为2的计数器
CountDownLatch latch = new CountDownLatch(2);
//计数器-1
latch.countDown();
//线程等待，等待至计数结束。
latch.await();
CyclicBarrier：多个线程相互等待，等待结束执行回调。
//创建一个初始值为2得计数器
CyclicBarrier barrier = new CyclicBarrier(2,
()->{ executor.execute(()->check()); //回调函数
});
//等待
barrier.await();
- 调用await()计数器减1，同时等待计数器变为0。
- 当计数器减到0时持有barrier.await()的线程会向下执行，同时调用barrier的回调函数。
- 可以循环利用，具备自动重置功能。
总结：
CountDownLatch主要用来解决一个线程等待多个线程的场景，可以类比旅游团团长要等待所有的游客到齐才能去下一个景点；而CyclicBarrier是一组线程之间互相等待 ，更像 是几个驴友之间不离不弃。除此之外CountDownLatch的计数器是不能循环利用的，也就是说一旦计数器减到0，再有线程调用await()，该线程会直接通过。但CyclicBarrier的计数器是可以循环利用的，而且具备自动重置的功能，一旦计数器减到0会自动重置到你设置的初始值。除此之外，CyclicBarrier还可以设置回调函数。
**** 码字不易如果对你有帮助请给个关注****
**** 爱技术爱生活 QQ群: 894109590****
