Java多线程--10 CountDownLatch


        CountDownLatch是一个倒计数器,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法,所以在当前计数到达零之前,await 方法会一直受阻塞。之后,会释放所有等待的线程,await 的所有后续调用都将立即返回。这种现象只出现一次>>计数无法被重置。如果需要重置计数,请考虑使用 CyclicBarrier。

        CountDownLatch有很多用途:

        1、将计数 1 初始化的 CountDownLatch 用作一个简单的开/关锁存器,或入口:在通过调用 countDown() 的线程打开入口前,所有调用 await 的线程都一直在入口处等待。

        2、用 N 初始化的 CountDownLatch 可以使一个线程在 N 个线程完成某项操作之前一直等待,或者使其在某项操作完成 N 次之前一直等待。典型用法是,将一个问题分成 N 个部分,用执行每个部分并让锁存器倒计数的 Runnable 来描述每个部分,然后将所有 Runnable 加入到 Executor 队列。当所有的子部分完成后,协调线程就能够通过 await。(当线程必须用这种方法反复倒计数时,可改为使用 CyclicBarrier。) 


        初始化CountDownLatch时,给定一个数N,await方法会阻塞线程,每调用countDown一下,N就减1 ,当N减到0时,就能执行await后面的程序。

import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {

	public static void main(String[] args) {
		
		final CountDownLatch countDown = new CountDownLatch(2);
		
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("进入线程t1" + "等待其他线程处理完成...");
					System.out.println("t1线程 getCount: " + countDown.getCount());
					countDown.await();
					System.out.println("t1线程继续执行...");
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		},"t1");
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t2线程进行初始化操作...");
					Thread.sleep(3000);
					System.out.println("t2线程初始化完毕,通知t1线程继续...");
					countDown.countDown();
					System.out.println("t2线程 getCount: " + countDown.getCount());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		Thread t3 = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					System.out.println("t3线程进行初始化操作...");
					Thread.sleep(4000);
					System.out.println("t3线程初始化完毕,通知t1线程继续...");
					countDown.countDown();
					System.out.println("t3线程 getCount: " + countDown.getCount());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
		
		t1.start();
		t2.start();
		t3.start();
	}
}

t1线程进入阻塞状态,t2和t3线程执行完成后,计数器值为0,阻塞解除,才会执行t1线程

打印:

t2线程进行初始化操作...

进入线程t1等待其他线程处理完成...

t3线程进行初始化操作...

t1线程 getCount: 2

t2线程初始化完毕,通知t1线程继续...

t2线程 getCount: 1

t3线程初始化完毕,通知t1线程继续...

t3线程 getCount: 0

t1线程继续执行...




多线程 CountDownLatch

2020.11.18 00:22

https://www.meihaocloud.com.com/316.html , 欢迎转载,请在文章页标出原文连接 !


Copyright © 2020 千夕网 联系站长

粤公网安备 44030302001408号 粤ICP备19099833号-1