关键词：

原文地址  译者：罗立树  校对：方腾飞

并发编程是一个难题，但是一个强大而简单的抽象可以显著的简化并发的编写。出于这样的考虑，Guava 定义了 ListenableFuture接口并继承了JDK concurrent包下的Future 接口。

我们强烈地建议你在代码中多使用ListenableFuture来代替JDK的 Future, 因为：

• 大多数Futures 方法中需要它。
• 转到ListenableFuture 编程比较容易。
• Guava提供的通用公共类封装了公共的操作方方法，不需要提供Future和ListenableFuture的扩展方法。
  

接口

传统JDK中的Future通过异步的方式计算返回结果:在多线程运算中可能或者可能在没有结束返回结果，Future是运行中的多线程的一个引用句柄，确保在服务执行返回一个Result。

ListenableFuture可以允许你注册回调方法(callbacks)，在运算（多线程执行）完成的时候进行调用,  或者在运算（多线程执行）完成后立即执行。这样简单的改进，使得可以明显的支持更多的操作，这样的功能在JDK concurrent中的Future是不支持的。

ListenableFuture 中的基础方法是addListener(Runnable, Executor), 该方法会在多线程运算完的时候，指定的Runnable参数传入的对象会被指定的Executor执行。

添加回调（Callbacks）

多数用户喜欢使用 Futures.addCallback(ListenableFuture<V>, FutureCallback<V>, Executor)的方式, 或者 另外一个版本version（译者注：addCallback(ListenableFuture<V> future,FutureCallback<? super V> callback)），默认是采用 MoreExecutors.sameThreadExecutor()线程池, 为了简化使用，Callback采用轻量级的设计.  FutureCallback<V> 中实现了两个方法:

• onSuccess(V),在Future成功的时候执行，根据Future结果来判断。
• onFailure(Throwable), 在Future失败的时候执行，根据Future结果来判断。

ListenableFuture的创建

对应JDK中的 ExecutorService.submit(Callable) 提交多线程异步运算的方式，Guava 提供了ListeningExecutorService 接口, 该接口返回 ListenableFuture 而相应的 ExecutorService 返回普通的 Future。将 ExecutorService 转为 ListeningExecutorService，可以使用MoreExecutors.listeningDecorator(ExecutorService)进行装饰。

01    ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(10));
02    ListenableFuture explosion = service.submit(new Callable() 
03      public Explosion call() 
04        return pushBigRedButton();
05      
06    );
07    Futures.addCallback(explosion, new FutureCallback() 
08      // we want this handler to run immediately after we push the big red button!
09      public void onSuccess(Explosion explosion) 
10        walkAwayFrom(explosion);
11      
12      public void onFailure(Throwable thrown) 
13        battleArchNemesis(); // escaped the explosion!
14      
15    );

另外, 假如你是从 FutureTask转换而来的, Guava 提供ListenableFutureTask.create(Callable<V>) 和ListenableFutureTask.create(Runnable, V). 和 JDK不同的是, ListenableFutureTask 不能随意被继承（译者注：ListenableFutureTask中的done方法实现了调用listener的操作）。

假如你喜欢抽象的方式来设置future的值，而不是想实现接口中的方法，可以考虑继承抽象类AbstractFuture<V> 或者直接使用 SettableFuture 。

假如你必须将其他API提供的Future转换成 ListenableFuture，你没有别的方法只能采用硬编码的方式JdkFutureAdapters.listenInPoolThread(Future) 来将 Future 转换成 ListenableFuture。尽可能地采用修改原生的代码返回 ListenableFuture会更好一些。

Application

使用ListenableFuture 最重要的理由是它可以进行一系列的复杂链式的异步操作。

1    ListenableFuture rowKeyFuture = indexService.lookUp(query);
2    AsyncFunction<RowKey, QueryResult> queryFunction =
3    new AsyncFunction<RowKey, QueryResult>() 
4    public ListenableFuture apply(RowKey rowKey) 
5    return dataService.read(rowKey);
6    
7    ;
8    ListenableFuture queryFuture = Futures.transform(rowKeyFuture, queryFunction, queryExecutor);

其他更多的操作可以更加有效的支持而JDK中的Future是没法支持的.

不同的操作可以在不同的Executors中执行，单独的ListenableFuture 可以有多个操作等待。

当一个操作开始的时候其他的一些操作也会尽快开始执行–“fan-out”–ListenableFuture 能够满足这样的场景：促发所有的回调（callbacks）。反之更简单的工作是，同样可以满足“fan-in”场景，促发ListenableFuture 获取（get）计算结果，同时其它的Futures也会尽快执行：可以参考 the implementation of Futures.allAsList 。（译者注：fan-in和fan-out是软件设计的一个术语，可以参考这里：http://baike.baidu.com/view/388892.htm#1或者看这里的解析Design Principles: Fan-In vs Fan-Out，这里fan-out的实现就是封装的ListenableFuture通过回调，调用其它代码片段。fan-in的意义是可以调用其它Future）

AsyncFunction<A, B> 中提供一个方法ListenableFuture<B> apply(A input)，它可以被用于异步变换值。

1    List<ListenableFuture> queries;
2    // The queries go to all different data centers, but we want to wait until they‘re all done or failed.
3     
4    ListenableFuture<List> successfulQueries = Futures.successfulAsList(queries);
5     
6    Futures.addCallback(successfulQueries, callbackOnSuccessfulQueries);

CheckedFuture

Guava也提供了 CheckedFuture<V, X extends Exception> 接口。CheckedFuture 是一个ListenableFuture ，其中包含了多个版本的get 方法，方法声明抛出检查异常.这样使得创建一个在执行逻辑中可以抛出异常的Future更加容易 。将 ListenableFuture 转换成CheckedFuture，可以使用 Futures.makeChecked(ListenableFuture<V>, Function<Exception, X>)。

googleguava官方教程(代码片段)

原文链接译文链接译者:沈义扬，罗立树，何一昕，*武祖*校对：方腾飞引言Guava工程包含了若干被Google的Java项目广泛依赖的核心库，例如：集合[collections]、缓存[caching]、原生类型支持[primitivessupport]、并发库[concurrencylibraries]、通... 查看详情

googleguava官方教程（中文版）

 原文链接  译文链接 译者: 沈义扬，罗立树，何一昕，武祖 校对：方腾飞引言Guava工程包含了若干被Google的Java项目广泛依赖的核心库，例如：集合[collections]、缓存[caching]、原生类型支持[primitivessupport]、并... 查看详情

googleguava和apachecommons哪个好

参考技术AGuava的FAQ部分有专门解答：WhydidGooglebuildallthis,whenitcouldhavetriedtoimprovetheApacheCommonsCollectionsinstead?TheApacheCommonsCollectionsveryclearlydidnotmeetourneeds.Itdoesnotusegenerics,whichisaproblemforusaswehatetogetcompilationwarningsfromourcode.Ithasalsobeenina"... 查看详情

googleguava-字符串处理(代码片段)

#（一）连接器[Joiner]packagecom.jcx.guava.utilites;importcom.google.common.base.Joiner;importcom.google.common.io.Files;importorg.junit.Test;importjava.io.File;importjava.io.FileWriter;importjava.io.IOExcep 查看详情

googleguava的消息总线：eventbus，java(代码片段)

googleguava的消息总线：EventBus，Javapom.xml添加引用：<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>31.1-jre</ve 查看详情

googleguava的消息总线：eventbus，java(代码片段)

googleguava的消息总线：EventBus，Javapom.xml添加引用：<dependency><groupId>com.google.guava</groupId><artifactId>guava</artifactId><version>31.1-jre</ve 查看详情

googleguava缓存分析

   这篇文章我们分析一下guava缓存的优缺点。guava缓存过期时间分为两种，一种是从写入时开始计时，一种是从最后访问时间开始计时，而且guava缓存的过期时间是设置到整个一组缓存上的；这和EHCache，redis，memcached等... 查看详情

googleguava中的前置条件(代码片段)

前置条件：让方法调用的前置条件判断更简单。Guava在Preconditions类中提供了若干前置条件判断的实用方法，我们建议[在Eclipse中静态导入这些方法]每个方法都有三个变种：checkArgument()方法，用来检查传入的值是否为true。booleanflag... 查看详情

[googleguava]1.3-常见object方法

原文链接 译者: 沈义扬equals当一个对象中的字段可以为null时，实现Object.equals方法会很痛苦，因为不得不分别对它们进行null检查。使用Objects.equal帮助你执行null敏感的equals判断，从而避免抛出NullPointerException。例如:Objects.e... 查看详情

使用googleguava做内存缓存

 前几天搞了一天，用redis做缓存，还没用两天，今天负责人要我改用谷歌提供的guava做缓存，说是因为redis用的是集群，不符合项目要求，所以今天上午研究了一下guava的缓存，并成功运行，我对比前两天用到的redis，感觉guava... 查看详情

googleguava之常见object方法(代码片段)

文中所述Guava版本基于29.0-jre，文中涉及到的代码完整示例请移步Github查看。常见Obejct方法使用Java中所有的类都有一个隐藏的公共父类，就是Object类。既然所有的类都继承自Object类，那所有的类中都包含有Object类的方法，常见的... 查看详情

googleguava之常见object方法(代码片段)

文中所述Guava版本基于29.0-jre，文中涉及到的代码完整示例请移步Github查看。常见Obejct方法使用Java中所有的类都有一个隐藏的公共父类，就是Object类。既然所有的类都继承自Object类，那所有的类中都包含有Object类的方法，常见的... 查看详情

googleguava并发编程-listenablefuture(代码片段)

    并发编程在咱们实际开发过程中肯定经常用到。比如线程池呀、通过Future去获取任务的执行结果呀等等。Guava从实际出发，为了方便我们的使用对JDK里面原生的一些并发编程方式做了增强。    Guava里面并发编程相关... 查看详情

googleguava工具类库的介绍和使用(代码片段)

...3;📣哈喽！大家好，今天给大家分享一篇有关Googleguava工具类库的简单介绍以及使用；并演示了一些集合中常见的操作，附有代码演示示例，便于学习；✨个人博客：https://blog.csdn.n 查看详情

真正的缓存之王，googleguava只是弟弟(代码片段)

来源：cnblogs.com/rickiyang/p/11074158.html1.CaffineCache在算法上的优点-W-TinyLFU2.使用2.1缓存填充策略2.2回收策略3.移除事件监听4.写入外部存储5.统计3.SpringBoot中默认Cache-CaffineCache1.引入依赖：2.添加注解开启缓存支持3.配置文件的... 查看详情

[googleguava]字符串处理：连接器拆分器字符匹配器

一、连接器【Joiner】二、拆分器【Splitter】三、字符匹配器【CharMatcher】　　四、字符集【Charsets】　　Charsets:针对所有Java平台都要保证支持的六种字符集提供了常量引用。尝试使用这些常量，而不是通过名称获取字符集实例。... 查看详情

别再重复造轮子了，推荐使用googleguava开源工具类库，真心强大！(代码片段)

GoogleGuava概述1、Guava是一组来自Google的核心Java库，包括新的集合类型（如multimap和multiset）、不可变集合、图形库以及用于并发、I/O、散列、缓存、原语、字符串等的实用程序！被广泛应用于Google的大多数Java项目... 查看详情

字符串操作—googleguava(代码片段)

...使用Guava中的Strings和Splitter字符串操作工具类。如何使用GoogleGuava会同步到MavenCentral中，所以，如果你是Maven项目的话只需要在pom.xml文件中引入如下依赖即可：<dependency><groupId>com.google.guava</groupId><artifactId>guava<... 查看详情