Future接口理论知识

Future接口：定义了操作异步任务执行一些方法，如获取异步任务的执行结果，取消任务的执行，判断任务是否被取消，判断任务执行是否完毕等。

Future接口能干什么：Java5新加的一个接口，它提供了一种异步行计算的功能。如果主线程需要执行一个很耗时的计算任务，我们就可以通过future把这个任务放到异步线程中执行。主线程继续处理其他任务或者先行结束，再通过Future获取计算结果。

目的：异步多线程任务执行且返回有结果，三个特点：多线程/有返回/异步任务

比如：（班长为老师买水作为新启动的异步多线程任务且买到水有结果返回）

比如主线程让一个子线程去执行任务，子线程可能比较耗时，启动子线程开始执行任务后，主线程就去做其他事情了，忙其他事情或者先执行完，过了一会去获取子任务的执行结果或变更的任务状态。

优点：future+线程池异步多线程任务配合，能显著提高程序的执行效率。

如果轮询的时候直接去获取get()时，

get容易导致阻塞，一般建议放在程序后面，一旦调用不见不散，非要等到结果才会离开，不管你是否计算完成，容易程序堵塞。假如我不愿意等待很长时间，我希望过时不候，可以自动离开.

get():一旦调用get()方法求结果，如果计算没有完成容易导致程序阻塞，

isDone()轮询:轮询的方式会耗费无谓的CPU资源，而且也不见的能及时的得到计算结果，如果想要异步获取结果，通常会以轮询的方式去回去结果，尽量不要阻塞。

实例代码：

        FutureTask futureTask = new FutureTask( () -> {
            System.out.println(Thread.currentThread().getName()+"t -----come in");
            try { TimeUnit.SECONDS.sleep(5); } catch (InterruptedException e) { e.printStackTrace(); }
            return "task over";
        });
        Thread t1 = new Thread(futureTask, "t1");
        t1.start();

        System.out.println(Thread.currentThread().getName()+"t ----忙其它任务了");

        //System.out.println(futureTask.get());
        //System.out.println(futureTask.get(3,TimeUnit.SECONDS));

        while(true)
        {
            if(futureTask.isDone())
            {
                System.out.println(futureTask.get());
                break;
            }else{
                //暂停毫秒
                try { TimeUnit.MILLISECONDS.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); }
                System.out.println("正在处理中，不要再催了，越催越慢 ，再催熄火");
            }
        }

为什么出现CompletableFuture:get()方法在Future计算完成之前会一直处在阻塞状态，

isDone（）方法容易消耗资源，对于真正的异步处理我们希望是可以通过传入回调函数，在Future结束时自动调用该回调函数，这样，我们就不要等待结果。

阻塞的方式和异步编程的设计理念相违背，而轮询的方式会耗费无谓的CPU资源。因此，JDK8设计了CompletableFuture。

CompletableFuture提供了一种观察者模式类似的机制，可以让任务执行完成后通知监听的一方。

Future接口理论知识

Java相关栏目本月热门文章