文档章节

Java借助CountDownLatch完成异步回调

Acce1erator
 Acce1erator
发布于 2017/01/24 09:52
字数 417
阅读 1873
收藏 101
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提供的一个简单的线程监测工具
         * 基于简单的计数,调用countDown()方法表明当前线程已经终止
         * 在监测线程中调用await()方法,该方法会一直挂起直到所有其它线程终止
         */
        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();
            }
        }
    }
}

这里有两点需要补充:

1.如果你是用main方法启动的线程,这种调用方法是没有问题的,JDK会确保所有线程都终止以后main方法才退出。但是如果main方法不是异步任务的启动者(如JUnit,Spring,Tomcat),一旦启动之后laucher将会失去对线程的控制。如在JUnit中laucher提交完任务后就会被认为所有过程已完成,其它线程会被强行终止。

2.正因为如此,请根据环境使用正确的Executor。比如,在web环境中,应该选用tomcat(或Spring)管理的线程池作为Executor,这样才能确保web应用对于异步任务的整个生命周期具有控制权;如果你选用JDK的线程池有什么后果呢?任务也许可以正常执行,当一旦你终止web-app,正在执行的异步线程并不会被正常kill掉,并由此造成内存泄漏或其它不可预见的后果。

© 著作权归作者所有

Acce1erator
粉丝 23
博文 25
码字总数 18001
作品 0
朝阳
程序员
私信 提问
加载中

评论(2)

Acce1erator
Acce1erator 博主
了解没有那么深入 受教受教
YanbinQ
YanbinQ
Executors.newCachedThreadPool() 中的线程是 isDaemon true.
我翻到了 13 年也研究了一下 CountDownLatch 协调线程 的使用 http://unmi.cc/countdownlatch-threads/。
CountDownLatch 是 Java 1.5 加入的 API, 到了 Java 8 我会选择使用 CompletableFuture, 它要等待所有线程是否完成可以简单调用
CompletableFuture.allOf(CompletableFuture...completableFutures)
就是其他框架的 waitAll() 的机制。
【并发编程】Future模式添加Callback及Promise 模式

Future Future是Java5增加的类,它用来描述一个异步计算的结果。你可以使用 isDone 方法检查计算是否完成,或者使用 get 方法阻塞住调用线程,直到计算完成返回结果。你也可以使用 cancel 方...

weknow
05/17
550
5
计数器:CountDownLatch,CountDownLatch,CyclicBarrier

计数器 CountDownLatch: 一个线程等待多个线程。 CyclicBarrier:多个线程相互等待,等待结束执行回调。 调用await()计数器减1,同时等待计数器变为0。 当计数器减到0时持有barrier.await()...

刘一草
09/24
20
0
2018-07-13期 Zookeeper客户端基本操作【本人亲自反复验证通过分享】

说明:本文档主要给大家介绍ZK客户端API基本操作 一、新建Java工程 1、New->Project->Java Project 填写JAVA工程名字,选择JDK版本等 2、为新建的Java工程添加外部jar包 工程名称->Java Buil...

JackmaSong
2018/07/13
0
0
Guava 源码分析(Cache 原理【二阶段】)

前言 在上文「Guava 源码分析(Cache 原理)」中分析了 的相关原理。 文末提到了回收机制、移除时间通知等内容,许多朋友也挺感兴趣,这次就这两个内容再来分析分析。 在开始之前先补习下 Ja...

crossoverJie
2018/07/16
0
0
CompletableFuture 的同步与异步

CompletableFuture 类声明了 CompletionStage 接口,CompletionStage 接口实际上提供了同步或异步运行计算的舞台。 所谓异步调用其实就是实现一个可无需等待被调用函数的返回值而让操作继续运...

秋风醉了
2018/11/04
342
0

没有更多内容

加载失败,请刷新页面

加载更多

川普给埃尔多安和内堪尼亚胡的信

任性 https://twitter.com/netanyahu/status/1186647558401253377 https://edition.cnn.com/2019/10/16/politics/trump-erdogan-letter/index.htm...

Iridium
7分钟前
3
0
golang-mysql-原生

db.go package mainimport ("database/sql""time"_ "github.com/go-sql-driver/mysql")var (db *sql.DBdsn = "root:123456@tcp(127.0.0.1:3306)/test?charset=u......

李琼涛
35分钟前
2
0
编程作业20191021092341

1编写一个程序,把用分钟表示的时间转换成用小时和分钟表示的时 间。使用#define或const创建一个表示60的符号常量或const变量。通过while 循环让用户重复输入值,直到用户输入小于或等于0的值...

1李嘉焘1
35分钟前
4
0
Netty整合Protobuffer

现在我们都知道,rpc的三要素:IO模型,线程模型,然后就是数据交互模型,即我们说的序列化和反序列化,现在我们来看一下压缩比率最大的二进制序列化方式——Protobuffer,而且该方式是可以跨...

算法之名
41分钟前
18
0
如何用C++实现栈

栈的定义 栈(stack)又名堆栈,它是一种运算受限的线性表。限定仅在表尾进行插入和删除操作的线性表。这一端被称为栈顶,相对地,把另一端称为栈底。向一个栈插入新元素又称作进栈、入栈或压...

BWH_Steven
59分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部