CountDownLatch使用 多线程 控制
CountDownLatch用法解释:
CountDownLatch要是控制多线程操作时,等待多线程执行完后,再执行下去。
举个例子,冲泡面,需要以下3个步骤
A:装水到电锅,打开电源,等3分钟
B:拆方便盒,放调味料
C:倒开水到方便面盒。
其中A跟B是可以同时进行的,C则需要依赖A,B完成了再执行。
代码参数:
实始化:CountDownLatch latch = new CountDownLatch(3) ,表示 count初始化为2个。
wait方法:表示等待count=0时,执行。
countDown方法:count减1。
实例:
上面说的冲泡面的生活例子。
代码实现:
import java.util.concurrent.CountDownLatch;
public class ClassTestApplication {
public static void main(String[] args) {
final CountDownLatch latch = new CountDownLatch(2); //初始化,count=3
System.out.println("Count="+latch.getCount());
new Thread(() -> {
System.out.println("开始煮开水。。。");
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("开水煮好了。。。");
latch.countDown(); //count = count -1;
System.out.println("Count="+latch.getCount());
}).start();
new Thread(() -> {
System.out.println("拆方便面盒。。。");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("方便面盒拆好了。。。");
latch.countDown(); //count = count -1;
System.out.println("Count="+latch.getCount());
}).start();
try {
latch.await();
System.out.println("水煮好了,面拆好了,充水到面盒。。。");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
执行结果如下:
Count=2
开始煮开水。。。
拆方便面盒。。。
方便面盒拆好了。。。
Count=1
开水煮好了。。。
Count=0
水煮好了,面拆好了,充水到面盒。。。