作者：多米音乐_35946826 | 来源：互联网 | 2023-10-15 16:29
系列目录Guava1:概览Guava2:Basicutilities基本工具Guava3:集合CollectionsGuava4:GuavacacheGuava6:Concurre
系列目录
Guava 1: 概览
Guava 2: Basic utilities基本工具
Guava 3: 集合Collections
Guava 4: Guava cache
Guava 6: Concurrency
Guava 12: Guava EventBus源码剖析
一、引子
有点经验的工程师一定对多线程比较熟悉，JDK封装的FutureTask实现了这一功能。如下图：
FutureTask实现了RunnableFuture接口，而RunnableFuture接口继承了Future+Runnable共2个接口。因此，FutureTask支持线程执行任务run(),也支持get()等待任务完成、cancel()取消任务等。但是明显还是不够。
Guava的并发包，强大而简单的抽象，让编写正确的并发代码更简单
1.ListenableFuture接口
ListenableFuture接口并继承了JDK concurrent包下的Future 接口。配合Futures工具类，可以很方便的实现以下功能：
1）监听任务执行结果并执行回调方法。
2）提供方便的任务接口转换。
3）多线程并发执行取结果集合。
2.Service框架
抽象可开启和关闭的服务，帮助你维护服务的状态逻辑
二、简单应用
2.1 ListenableFuture接口
2.1.1 监听任务执行结果并执行回调方法
实现功能：
1）定义监听执行器。
2）定义可监听的带返回值任务。
3）定义回调方法。
3）绑定任务、执行器、回调方法。
源码如下：
1 public static void main(String[] args) throws ExecutionException, InterruptedException {
2 /** 1.典型用法：可监听的future,带回调方法 */
3 // 定义监听执行服务
4 ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
5 // 定义可监听的带返回值的任务
6 ListenableFuture callableListenableFuture1 = listeningExecutorService.submit(() -> {
7 System.out.println("callable1 call!");
8 return "1";
9 });
10 // 添加回调，由指定监听执行服务来执行，监听可监听的future,监听到事件时执行对应回调方法。
11 Futures.addCallback(callableListenableFuture1, new FutureCallback() {
12 @Override
13 public void onSuccess(@Nullable String result) {
14 System.out.println("success,result=" + result);
15 }
16
17 @Override
18 public void onFailure(Throwable t) {
19 System.out.println("fail!");
20 }
21 }, listeningExecutorService);
22 }
打印结果：
callable1 call!
success,result=1
2.1.2 提供方便的任务接口转换
实现功能：
1) 定义一个需要绑定的ListenableFuture
2)定义一个异步转换方法
3)定义一个线程任务执行器
4)调用Futures工具类的transformAsync方法实现转换
源码如下：
1 public static void main(String[] args) throws ExecutionException, InterruptedException {
2 /** 2.非典型用法：异步转换 */
3 // 异步转换，参数1是需要转换的listenableFuture,参数2是转换方法，参数3是执行转换的线程执行器（Runnable）。
4 ListenableFuture transform = Futures.transformAsync(callableListenableFuture1, new AsyncFunction() {
5 @Override
6 public ListenableFuture apply(@Nullable String input) {
7 return Futures.immediateFuture(Integer.parseInt(input));
8 }
9 }, MoreExecutors.directExecutor());
10 // 阻塞线程得到结果
11 System.out.println("阻塞获取转换后任务的结果："+transform.get());
12 }
打印结果：
2.1.3 多线程并发执行取结果集合
实现功能：
1）定义多个任务
2）调用Futures工具类的allAsList方法合并结果，返回一个总ListenableFuture,调用get方法即可实现多线程并发执行任务取结果集合，结果是list,顺序是按照提交任务的顺序。
源码如下：
1 public static void main(String[] args) throws ExecutionException, InterruptedException {
2 /** 3.典型用法：多任务并发执行取结果list */
3 // 可监听不带返回值的任务
4
5 ListenableFuture callableListenableFuture2 = listeningExecutorService.submit(() -> {
6 Thread.sleep(3000);
7 System.out.println("callable2 call!");
8 return "2";
9 });
10 ListenableFuture callableListenableFuture3 = listeningExecutorService.submit(() -> {
11 System.out.println("callable3 call!");
12 return "3";
13 });
14 ListenableFuture> listListenableFuture = Futures.allAsList(
15 Lists.newArrayList(callableListenableFuture1, callableListenableFuture2, callableListenableFuture3));
16 // 返回结果list就是添加任务的顺序
17 System.out.println("多任务并发执行取结果list result=" + listListenableFuture.get());
18 }
打印结果：
callable1 call!
callable3 call!
callable2 call!
多任务并发执行取结果list result=[1, 2, 3]
2.2 Service框架
Guava包里的Service接口用于封装一个服务对象的运行状态，包括start和stop等方法。例如web服务器，RPC服务器、计时器等可以实现这个接口。对此类服务的状态管理在多线程环境下尤为复杂。Guava包提供了一些基础类帮助你管理复杂的状态转换逻辑和同步细节。这里不细节拓展，很少情况会用到这个框架。
三、总结
Guava 提供了ListenableFuture接口，结合Futures工具类，可以非常方便的实现并发任务，取结果list等方法,且API优雅易用，在特定场景，建议使用。
相反，Service框架,可能重量级的业务场景才可能使用到，简单场景没有必要使用。
京公网安备 11010802041100号