基于Guava的异步线程结果监听：ListenableFuture

1.ListenableFuture概述：

ListenableFuture是对原有Future的增强，它可以监听异步执行的过程，执行完了，自动触发回调操作。
除此之外，可以分别针对成功或者失败的情况做后续处理。

2.使用场景

你想拿到异步处理的结果，但是你又不想线程一直堵塞在那边等异步结果的返回。

3.代码

package com.example.test.thread.future;import com.alibaba.nacos.shaded.com.google.common.util.concurrent.*;
import lombok.extern.slf4j.Slf4j;import java.time.LocalTime;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;/*** ListenableFuture是对原有Future的增强，* 可以用于监听Future任务的执行状况，是执行成功还是执行失败，并提供响应的接口用于对不同结果的处理。*/
@Slf4j
public class ListenableFutureTest {static ExecutorService executorService = Executors.newFixedThreadPool(5);public static void main(String[] args) {log.info("任务开始--- {}",LocalTime.now());// MoreExecutors类的静态方法listeningDecorator方法初始化一个ListeningExecutorService的方法ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(executorService);ListenableFuture<List<String>> future = listeningExecutorService.submit(() -> {TimeUnit.SECONDS.sleep(3);return Arrays.asList("A", "B", "C");});//通过Futures的静态方法addCallback给ListenableFuture添加回调函数Futures.addCallback(future, new FutureCallback<List<String>>() {@Overridepublic void onSuccess(List<String> result) {// 异步任务执行成功后的回调方法log.info(Thread.currentThread().getName() + ":异步任务执行成功，结果是：" + result + ",时间：" + LocalTime.now());//收到回调结果后，建议关注线程池，否则监听回调程序会一直阻塞，不会结束；listeningExecutorService.shutdown();}@Overridepublic void onFailure(Throwable t) {// 异步任务执行失败后的回调方法log.info("异步任务执行失败");t.printStackTrace();}}, executorService);log.info("{}:主线程继续执行其他任务... {}", Thread.currentThread().getName(), LocalTime.now());}
}