ListenableFuture应用场景

逃离我推掉我的手 2021-09-15 23:34 365阅读 0赞

ListenableFuture是对原有Future的增强，可以用于监听Future任务的执行状况，是执行成功还是执行失败，并提供响应的接口用于对不同结果的处理。

适用场景：

1、如果一个主任务开始执行，然后需要执行各个小任务，并且需要等待返回结果，统一返回给前端，此时Future和ListenableFuture作用几乎差不多，都是通过get()方法阻塞等待每个任务执行完毕返回。

2、 如果一个主任务开始执行，然后执行各个小任务，主任务不需要等待每个小任务执行完，不需要每个小任务的结果，此时用ListenableFuture非常合适，它提供的FutureCallBack接口可以对每个任务的成功或失败单独做出响应。

3、如果我们希望各个小任务一旦计算完成就拿到结果展示给用户(push出去)或者做另外的计算，就必须使用另一个线程不断的查询计算状态。这样做，代码复杂，而且效率低下。

public class ListenFutureTest {
     
        public static void main(String[] args) {
            testListenFuture();
        }
     
        public static void testListenFuture() {
            System.out.println("主任务执行完，开始异步执行副任务1.....");
            ListeningExecutorService pool = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(5));
            ListenableFuture<String> future = pool.submit(new Task());
            Futures.addCallback(future, new FutureCallback<String>() {
                @Override
                public void onSuccess(String result) {
                    System.out.println("成功,结果是:" + result);
                }
     
                @Override
                public void onFailure(Throwable t) {
                    System.out.println("出错,业务回滚或补偿");
                }
            });
            System.out.println("副本任务启动,回归主任务线，主业务正常返回2.....");
        }
    }
     
    class Task implements Callable<String> {
     
        @Override
        public String call() throws Exception {
            TimeUnit.SECONDS.sleep(1);
           // int a =1/0;
            return "task done";
        }
    }

结果是：

主任务执行完，开始异步执行副任务1.....  
副本任务启动,回归主任务线,主业务正常返回2.....  
**成功,结果是:task done**

**如果把Task的注释去掉int a =1/0会抛出异常，那么返回会是**

主任务执行完，开始异步执行副任务1.....  
副本任务启动,回归主任务线,主业务正常返回2.....  
**出错,业务回滚或补偿**

**由此可见，如果不采用此方法，需要另外起一个线程单独来计算状态可计算情况，非常麻烦，用ListenableFuture完美解决**