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>>() {
            @Override
            public void onSuccess(List<String> result) {
                // 异步任务执行成功后的回调方法
                log.info(Thread.currentThread().getName() + ":异步任务执行成功，结果是：" + result + ",时间：" + LocalTime.now());
                //收到回调结果后，建议关注线程池，否则监听回调程序会一直阻塞，不会结束；
                listeningExecutorService.shutdown();
            }
            @Override
            public void onFailure(Throwable t) {
                // 异步任务执行失败后的回调方法
                log.info("异步任务执行失败");
                t.printStackTrace();
            }
        }, executorService);
        log.info("{}:主线程继续执行其他任务... {}", Thread.currentThread().getName(), LocalTime.now());



    }
}

4.结果