Java CountDownLatch完成異步回調(diào)實(shí)例詳解
Java CountDownLatch完成異步回調(diào)實(shí)例詳解
實(shí)例代碼：
public class AsyncDemo {
private static void doSomeTask() {
System.out.println("Hello World");
}
private static void onCompletion() {
System.out.println("All tasks finished");
}
public static void main(String[] args) {
ExecutorService executor = Executors.newCachedThreadPool();
final CountDownLatch latch = new CountDownLatch(2);
executor.execute(new Task(latch));
executor.execute(new Task(latch));
executor.execute(() -> {
try {
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
onCompletion();
});
executor.shutdown();
}
private static class Task implements Runnable {
/**
* CountDownLatch 是JDK提供的一個(gè)簡(jiǎn)單的線程監(jiān)測(cè)工具
* 基于簡(jiǎn)單的計(jì)數(shù)，調(diào)用countDown()方法表明當(dāng)前線程已經(jīng)終止
* 在監(jiān)測(cè)線程中調(diào)用await()方法,該方法會(huì)一直掛起直到所有其它線程終止
*/
private final CountDownLatch latch;
public Task(CountDownLatch latch) {
this.latch = latch;
}
@Override
public void run() {
try {
doSomeTask();
} catch (Exception e) {
e.printStackTrace();
} finally {
latch.countDown();
}
}
}
}
這里有兩點(diǎn)需要補(bǔ)充：
1.如果你是用main方法啟動(dòng)的線程，這種調(diào)用方法是沒有問題的，JDK會(huì)確保所有線程都終止以后main方法才退出。但是如果main方法不是異步任務(wù)的啟動(dòng)者（如JUnit,Spring,Tomcat），一旦啟動(dòng)之后laucher將會(huì)失去對(duì)線程的控制。如在JUnit中l(wèi)aucher提交完任務(wù)后就會(huì)被認(rèn)為所有過程已完成，其它線程會(huì)被強(qiáng)行終止。
2.正因?yàn)槿绱?，?qǐng)根據(jù)環(huán)境使用正確的Executor。比如，在web環(huán)境中，應(yīng)該選用tomcat（或Spring）管理的線程池作為Executor，這樣才能確保web應(yīng)用對(duì)于異步任務(wù)的整個(gè)生命周期具有控制權(quán)；如果你選用JDK的線程池有什么后果呢？任務(wù)也許可以正常執(zhí)行，當(dāng)一旦你終止web-app，正在執(zhí)行的異步線程并不會(huì)被正常kill掉，并由此造成內(nèi)存泄漏或其它不可預(yù)見的后果。
感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！
相關(guān)文章
這篇文章主要介紹了Java中synchronized的優(yōu)化,介紹為了實(shí)現(xiàn)高效并發(fā)，虛擬機(jī)對(duì)synchronized 做的一系列的鎖優(yōu)化措施，本文給大家介紹的非常詳細(xì),需要的朋友可以參考下2023-05-05
這篇文章主要介紹了Java-編程式事務(wù)、Java-Stream、Linux常用命令,需要的朋友可以參考下2023-05-05
這篇文章主要介紹了Java定義泛型接口和類的方法,結(jié)合實(shí)例形式分析了泛型相關(guān)概念、原理及泛型接口與類的定義實(shí)現(xiàn)方法,需要的朋友可以參考下2019-08-08
解決springboot整合cxf啟動(dòng)報(bào)錯(cuò),原因是版本問題
這篇文章主要介紹了解決springboot整合cxf啟動(dòng)報(bào)錯(cuò),原因是版本問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
spring?aop?pointcut?添加多個(gè)execution方式
這篇文章主要介紹了spring?aop?pointcut?添加多個(gè)execution方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11
SpringBoot深入刨析數(shù)據(jù)層技術(shù)
這篇文章主要介紹了SpringBoot數(shù)據(jù)層技術(shù)的解析，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08
文章主要介紹了線上CMS服務(wù)內(nèi)存增長(zhǎng)問題的排查過程,通過分析GC日志和堆?？煺?定位問題為Nacos的NamingService對(duì)象無法回收和MySQL的CallableStatement對(duì)象增長(zhǎng)迅速,最終通過將NamingService改為單例模式解決了內(nèi)存增長(zhǎng)問題2025-03-03
詳解Spring注解--@Autowired、@Resource和@Service
本篇文章主要介紹最重要的三個(gè)Spring注解，也就是@Autowired、@Resource和@Service，具有很好的參考價(jià)值。下面跟著小編一起來看下吧2017-05-05
把這篇文章主要為大家介紹了如何保證RabbitMQ消息不丟失的解決方發(fā)，分從從丟失的三種情況給大家介紹不同的解決方案，感興趣的小伙伴可以參考閱讀本文2023-07-07
解決idea刪除模塊后重新創(chuàng)建顯示該模塊已經(jīng)被注冊(cè)的問題
這篇文章主要介紹了解決idea刪除模塊后重新創(chuàng)建顯示該模塊已經(jīng)被注冊(cè)的問題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2021-02-02