| 對(duì)比 | CountdownLatch | |
|---|---|---|
| 使用場(chǎng)景 | 某些任務(wù)等待直到另外一些任務(wù)都完成 | 某些任務(wù)完成后開始等待,等這些任務(wù)都完成后,它們才能進(jìn)入繼續(xù)執(zhí)行 |
| await()含義 | 當(dāng)前線程等待,直到count為0 | 標(biāo)識(shí)當(dāng)前線程已完成;count-1.如果count不為0,則阻塞等待;如果count等于0,所有參與線程解除阻塞,執(zhí)行在CyclicBarrier上定義的barrierAction. |
| 同步狀態(tài)維護(hù) | AbstractQueueSynchronizer | RetreenLock&Condition |
| 特有api | countdown: count-1 非阻塞 | reset: 重置count,進(jìn)入下一輪, 所有等待中的線程結(jié)束阻塞拋異常 |
| 重用性 | 僅能使用一次 | 可重置,多次使用 |
| 參與角色 | 兩種參與角色 一種await阻塞等待,另外一種countdown | 僅一種參與角色, 既是await又是countdown |
latch-barrier.png
Latch演示代碼
/**
* CountdownLatch演示
* count初始為3,
* 線程t1,t2,t3各自完成一項(xiàng)耗時(shí)任務(wù)(以sleep模擬),并在執(zhí)行結(jié)束后countdown
* 主線程await等待
*
* @author alonwang
* @date 2020/11/30 7:55 上午
*/
public class LatchDemo {
public static void main(String[] args) throws InterruptedException {
CountDownLatch latch = new CountDownLatch(3);
Runnable r = () -> {
//執(zhí)行一項(xiàng)耗時(shí)任務(wù)
try {
Thread.sleep(new Random().nextInt(3000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "執(zhí)行完畢...");
latch.countDown();
};
new Thread(r, "t1").start();
new Thread(r, "t2").start();
new Thread(r, "t3").start();
latch.await();
System.out.println("主線程執(zhí)行完畢 ...");
}
}
//output
CyclicBarrier演示代碼
/**
* 啟動(dòng)兩個(gè)線程,各自進(jìn)行一個(gè)耗時(shí)操作,完成后await.
* 兩個(gè)線程都到達(dá)此階段時(shí),觸發(fā)預(yù)先設(shè)定的barrierAction
*
* @author alonwang
* @date 2020/11/30 8:04 上午
*/
public class CyclicBarrierDemo {
public static void main(String[] args) throws InterruptedException {
CyclicBarrier barrier = new CyclicBarrier(2, () -> System.out.println("執(zhí)行barrierAction..."));
Runnable runnable = () -> {
try {
Thread.sleep(new Random().nextInt(3000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "開始await");
try {
barrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+ "執(zhí)行完畢");
};
new Thread(runnable, "t1").start();
new Thread(runnable, "t2").start();
Thread.sleep(5000);
}
}
//output
t2開始await
t1開始await
執(zhí)行barrierAction...
t2執(zhí)行完畢
t1執(zhí)行完畢
