Java多线程Future与FutureTask

Posted 2020-09-05

    一：Future

       在使用实现Callable创建线程时，call()方法是有返回值的。那么，我们在编程时用什么来代表这个 线程执行后才能返回的未来结果 呢？那就是 Future类型。

       顾名思义，Future——未来值，我们用这个未来值来代替编程中需要用到线程结果的地方，然后在实际运行时，通过 future.get() 方法来获取线程的真正运行结果。

       Future接口有一个泛型参数，其类型与call()方法的返回值类型要一致，也就是说，Future<V>  只是代表 V类型的未来值 而已，不是真的有值存在，需要用到这个具体的值时，就需用V类型的对象future通过get()获取线程的实际运行结果值。

 

    二：FutureTask

       FutureTask是一种可以取消的（在线程执行完成之前取消）异步线程，它实现了Runnable接口和Future接口，也就是说：它既可以运行线程，又可以携带返回结果。故：实现runnable创建的线程类、实现callable实现的线程类都可以包装成FutureTask对象进行启动。

       FutureTask实现了Future接口，故Future中的get()、isDone()、cancel()方法等都得到了具体实现，所以可以通过futuretask对象获取异步线程的执行结果、查询线程的完成状态、取消线程。

       FutureTask实现了Runable接口，所以它可以作为Thread类的构造参数被包装成thread类进行启动，也可以被提交给线程池的excute(futuretask)进行启动。

       使用过程：创建runnable实现类对象或callable实现类对象——创建FutureTask对象，把runnable实现类对象或callable实现类对象作为参数

                     ——创建Thread对象把futuretask对象作为参数，然后通过thread对象.start()启动，通过Future<V>类型的list保存异步结果

                     ——或者创建线程池，把futuretask对象作为参数交给excute(futuretask)启动，通过Future<V>类型的list保存异步结果

                    ——之后可以通过线程的isDone()查询线程完成状态，通过 cancel()取消线程，通过future结果的get()获取真正结果。（若在get()前线程调用了cancel()，则会抛出异常）