CountDownLatch:
允许一个或者多个线程去等待其他线程完成操作。
CountDownLatch
接收一个int
型参数,表示要等待的工作线程的个数。
方法:
方法 | 说明 |
await() | 使当前线程进入同步队列进行等待,直到latch 的值被减到0 或者当前线程被中断,当前线程就会被唤醒。 |
await(long timeout, TimeUnit unit) | 带超时时间的await() |
countDown() | 使latch 的值减1 ,如果减到了0 ,则会唤醒所有等待在这个latch 上的线程。 |
getCount() | 获得latch 的数值。 |
代码示例:
//创建线程池,线程池的核心数可根据业务场景进行动态调整
ExecutorService executorService = Executors.newFixedThreadPool(10);
//如果有n个线程,那么就指定CountDownLatch 的计数器为 n
final CountDownLatch latch = new CountDownLatch(10);
for (int j = 0; j <10 ; j++) {
executorService.execute(()->{
log.info("子线程 start time:{},线程名称:{}", DateUtil.now(),Thread.currentThread().getName());
//此处是需要执行的业务操作
log.info("子线程 end time:{},线程名称:{}", DateUtil.now(),Thread.currentThread().getName());
//当前线程调用此方法,则计数器减一
latch.countDown();
});
}
try {
//主线程调用此方法,直到计数器的数值为0,主线程才开始处理
latch.await();
log.info("所有子线程执行完毕,主线程继续执行");
} catch (InterruptedException e) {
e.printStackTrace();
}
//销毁线程池
executorService.shutdown();
文章总结:
CountDownLatch主要有两个方法:
countDown()和await()。
countDown()方法:用于使计数器减一,其一般是执行任务的线程调用;
await()方法:则使调用该方法的线程处于等待状态,其一般是主线程调用。
这里需要注意的是:countDown()方法并没有规定一个线程只能调用一次,当同一个线程调用多次countDown()方法时,每次都会使计数器减一;另外,await()方法也并没有规定只能有一个线程执行该方法,如果多个线程同时执行await()方法,那么这几个线程都将处于等待状态,并且以共享模式享有同一个锁。