摘要：本人郵箱歡迎轉(zhuǎn)載轉(zhuǎn)載請注明網(wǎng)址代碼已經(jīng)全部托管有需要的同學(xué)自行下載引言有一個同步助手可以讓一個或一些線程等待直到另外一些線程執(zhí)行完一些操作這就是理論在初始化的時候需要一個參數(shù)調(diào)用的線程會一直等待直到其他線程調(diào)用使清空為通常所有等待中的線程會
本人郵箱:
歡迎轉(zhuǎn)載,轉(zhuǎn)載請注明網(wǎng)址 http://blog.csdn.net/tianshi_kco
github: https://github.com/kco1989/kco
代碼已經(jīng)全部托管github有需要的同學(xué)自行下載
引言
有一個同步助手,可以讓一個或一些線程等待直到另外一些線程執(zhí)行完一些操作.這就是CountDownLatch
理論
CountDownLatch在初始化的時候需要一個count參數(shù).調(diào)用await()的線程會一直等待,直到其他線程調(diào)用countDown使count清空為0.通常所有等待中的線程會被釋放并且后面繼續(xù)調(diào)用await的線程會立即返回.這個是一次性操作,count不能被重置的.如果想要被重置的話,就可以參考(九)java多線程之CyclicBarrier
CountDownLatch(int count) 構(gòu)造一個指定count的CountDownLatch
await() 如果當(dāng)前的count為0的話,則會立即返回,否則當(dāng)前線程一直等待,直到以下情況至少發(fā)生一個
其他線程調(diào)用countDown使count清空為0
當(dāng)前線程被其他線程中斷
await(long timeout, TimeUnit unit) 如果當(dāng)前的count為0的話,則會立即返回,否則當(dāng)前線程一直等待,直到以下情況至少發(fā)生一個
其他線程調(diào)用countDown使count清空為0
當(dāng)前線程被其他線程中斷
指定的時間超時
countDown() 如果當(dāng)前的count大于0,則count減1,否則,所有等待的線程重新獲得執(zhí)行機(jī)會
例子
我們還是用上一篇文章旅游做例子吧.小明,小剛,小紅","小麗,小黑,小白他們六個最后旅游回來時坐飛機(jī),飛機(jī)上就有空姐啦.那么等他們六個人下飛機(jī)之后,空姐就要考試清理垃圾啦,檢查設(shè)備等等,這些事情都必須飛機(jī)上的全部乘客下機(jī)之后才能做.行,按照這個場景,我們編寫一下程序吧.
首先,想定義一個飛機(jī)類 Airplane, 里面包含乘客下機(jī)和空姐的清理工作
public class Airplane {
private CountDownLatch countDownLatch;
private Random random;
public Airplane(int peopleNum){
countDownLatch = new CountDownLatch(peopleNum);
random = new Random();
}
/**
* 下機(jī)
*/
public void getOffPlane(){
try {
String name = Thread.currentThread().getName();
Thread.sleep(random.nextInt(500));
System.out.println(name + " 在飛機(jī)在休息著....");
Thread.sleep(random.nextInt(500));
System.out.println(name + " 下飛機(jī)了");
countDownLatch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public void doWork(){
try {
String name = Thread.currentThread().getName();
System.out.println(name + "準(zhǔn)備做 清理 工作");
countDownLatch.await();
System.out.println("飛機(jī)的乘客都下機(jī)," + name + "可以開始做 清理 工作");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
最后,就可以直接寫測試類
public class TestMain {
public static void main(String[] args) {
String visitor = "明剛紅麗黑白";
String kongjie = "美惠花";
Airplane airplane = new Airplane(visitor.length());
Set threads = new HashSet<>();
for (int i = 0; i < visitor.length(); i ++){
threads.add(new Thread(() -> {
airplane.getOffPlane();
}, "小" + visitor.charAt(i)));
}
for (int i = 0; i < kongjie.length(); i ++){
threads.add(new Thread(() ->{
airplane.doWork();
}, "小" + kongjie.charAt(i) + "空姐"));
}
for (Thread thread : threads){
thread.start();
}
}
}
運(yùn)行一下結(jié)果:
小花空姐準(zhǔn)備做 清理 工作
小惠空姐準(zhǔn)備做 清理 工作
小美空姐準(zhǔn)備做 清理 工作
小麗 在飛機(jī)在休息著....
小明 在飛機(jī)在休息著....
小白 在飛機(jī)在休息著....
小剛 在飛機(jī)在休息著....
小剛 下飛機(jī)了
小明 下飛機(jī)了
小黑 在飛機(jī)在休息著....
小麗 下飛機(jī)了
小紅 在飛機(jī)在休息著....
小紅 下飛機(jī)了
小白 下飛機(jī)了
小黑 下飛機(jī)了
飛機(jī)的乘客都下機(jī),小花空姐可以開始做 清理 工作
飛機(jī)的乘客都下機(jī),小美空姐可以開始做 清理 工作
飛機(jī)的乘客都下機(jī),小惠空姐可以開始做 清理 工作
通過結(jié)果可以發(fā)現(xiàn),空姐都是等所有的乘客下飛機(jī)之后,才做清理工作的.結(jié)果正確,無毛病.
打賞
如果覺得我的文章寫的還過得去的話,有錢就捧個錢場,沒錢給我捧個人場(幫我點(diǎn)贊或推薦一下)
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/69913.html
