注册 X
提交 注:点击提交后系统会发送邮件到邮箱验证!(仅支持中国大陆邮箱)
我已阅读并同意 服务条款
首页 > IT技术笔记 > 查看笔记

java高并发系列 - 第34篇:google提供的一些好用的并发工具类

java高并发系列第34篇。

环境:jdk1.8。

关于并发方面的,juc已帮我们提供了很多好用的工具,而谷歌在此基础上做了扩展,使并发编程更容易,这些工具放在guava.jar包中。

本文演示几个简单的案例,见一下guava的效果。

guava maven配置

        
        
      

guava中常用几个类

MoreExecutors​:提供了一些静态方法,是对juc中的Executors类的一个扩展。 ​Futures​:也提供了很多静态方法,是对juc中Future的一个扩展。

案例1:异步执行任务完毕之后回调

        
        
      

输出:

        
        
      

说明:

ListeningExecutorService接口继承于juc中的ExecutorService接口,对ExecutorService做了一些扩展,看其名字中带有Listening,说明这个接口自带监听的功能,可以监听异步执行任务的结果。通过MoreExecutors.listeningDecorator创建一个ListeningExecutorService对象,需传递一个ExecutorService参数,传递的ExecutorService负责异步执行任务。

ListeningExecutorServicesubmit方法用来异步执行一个任务,返回ListenableFutureListenableFuture接口继承于juc中的Future接口,对Future做了扩展,使其带有监听的功能。调用submit.addListener可以在执行的任务上添加监听器,当任务执行完毕之后会回调这个监听器中的方法。

ListenableFutureget方法会阻塞当前线程直到任务执行完毕。

上面的还有一种写法,如下:

        
        
      

输出:

        
        
      

上面通过调用Futures的静态方法addCallback在异步执行的任务中添加回调,回调的对象是一个FutureCallback,此对象有2个方法,任务执行成功调用onSuccess,执行失败调用onFailure

失败的情况可以将代码中int i = 10 / 0;注释去掉,执行一下可以看看效果。

示例2:获取一批异步任务的执行结果

        
        
      

输出:

        
        
      

结果中按顺序输出了6个异步任务的结果,此处用到了Futures.allAsList方法,看一下此方法的声明:

        
        
      

传递一批ListenableFuture,返回一个ListenableFuture<List<V>>,内部将一批结果转换为了一个ListenableFuture对象。

示例3:一批任务异步执行完毕之后回调

异步执行一批任务,最后计算其和

        
        
      

输出:

        
        
      

代码中异步执行了一批任务,所有任务完成之后,回调了上面的onSuccess方法,内部对所有的结果进行sum操作。

总结

  • 通过guava提供的一些工具类,方便异步执行任务并进行回调
  • guava内部还有很多好用的工具类,有兴趣的可以去研究一下

 打赏        分享



评论

邮箱: 昵称: