写点什么

Java 多线程 Future 和 FutureTask 的区别

作者:Yeats_Liao
  • 2022-10-16
    江西
  • 本文字数:2300 字

    阅读完需:约 1 分钟

一、说明

Future 和 FutureTask 的关系


  • Future 是一个接口,无法直接创建对象,需配合线程池使用.submit()方法返回值Future来保存执行结果;而使用.execute()方法传入Runnable接口无返回值

  • FutureTask 是一个类,可以直接创建对象,其实现了RunnableFuture接口(继承Future接口)


使用区别


  • 就是一个接口和实现类的不同写法

二、理解

Future


  • java.util.concurrent包下Future<V>接口,对RunnableCallable对象执行任务完成后获取执行结果


public interface Future<V> {    boolean cancel(boolean mayInterruptIfRunning);    boolean isCancelled();    boolean isDone();    V get() throws InterruptedException, ExecutionException;    V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException;}
复制代码


  • mayInterruptRunning 表示是否中断执行中的线程

  • boolean cancel() 尝试取消任务的执行,如果任务已经完成或已被取消,则返回 false;如果任务已经启动,将以中断执行线程的方式停止该任务,停止成功则返回 true

  • boolean isDone()若任务完成,则返回 true

  • boolean isCancelled() 若任务在完成前取消,则返回 true

  • get() 获取执行结果,必须等待任务完成后才返回结果

  • get(long timeout, TimeUnit unit) 获取执行结果,timeout 表示等待的最长时间,unit 表示时间单位,在指定时间内还没获取到结果,则返回 null


FutureTask


  • java.util.concurrent包下实现RunnableFuture<V>接口,可实现Runnable接口执行线程,也可实现Future接口获取执行结果


public class FutureTask<V> implements RunnableFuture<V> {  ……}
复制代码


  • RunnableFuture接口继承Runnable


public interface RunnableFuture<V> extends Runnable, Future<V> {    void run();}
复制代码


FutureTask 执行状态


  • 根据方法执行的时机,FutureTask 可处于以下三种行状态



FutureTask 方法执行示意图


  • .cancel(ture)会中断线程停止任务,适用于长时间处于运行的任务,并且能够处理 interruption

  • .cancel(false)会让线程正常执行至完成,并返回 false,适用于未能处理 interruption 的任务,或者不清楚是否支持取消的任务,以及等待已经开始的任务执行完成


三、实现

1.实现接口

创建CallableThreadDemo类实现Callable接口


public class CallableThreadDemo implements Callable{    @Override    public String call() throws Exception {        System.out.println("Callable子线程: " +Thread.currentThread().getName()+ " 开启");        return "我是Callable子线程: " +Thread.currentThread().getName()+ " 产生的结果";    }}
复制代码

2.使用 Future

创建CallableTest类执行测试,将创建好的线程对象通过.submit()方法提交到线程池去执行,线程执行后,返回值Future可被拿到


public class CallableTest {    public static void main(String[] args) {        // 1.创建线程池        ExecutorService executorService = Executors.newSingleThreadExecutor();        // 2.创建Callable子线程对象任务        CallableThreadDemo callableThread_1 = new CallableThreadDemo();        // 3.提交任务到线程池        Future future = executorService.submit(callableThread_1);        // 4.获取执行结果        try {            System.out.println("主线程开始执行");
System.out.println("主线程要取得Callable子线程的结果"); if (future.get()!=null){ //输出获取的结果 System.out.println(future.get()); }else { //输出未获取到结果 System.out.println("future.get()未获取到结果"); } } catch (InterruptedException e){ e.printStackTrace(); }catch (Exception e) { e.printStackTrace(); } // 5.关闭线程池 executorService.shutdown(); System.out.println("主线程执行完成"); }}
复制代码


3.使用 FutureTask

创建FutureTask对象,提交任务到线程池,可以交给Executor执行,或将创建好的线程对象通过.submit()方法提交到线程池去执行,线程执行后,返回值FutureTask可被拿到


public class CallableTest {    public static void main(String[] args) {        // 1.创建线程池        ExecutorService executorService = Executors.newSingleThreadExecutor();        // 2.创建Callable子线程对象任务        CallableThreadDemo callableThread_1 = new CallableThreadDemo();        // 3.提交任务到线程池        FutureTask futureTask = new FutureTask(callableThread_1);        executorService.submit(futureTask);        // 4.获取执行结果        try {            System.out.println("主线程开始执行");
System.out.println("主线程要取得Callable子线程的结果"); if (futureTask.get()!=null){ //输出获取的结果 System.out.println(futureTask.get()); }else { //输出未获取到结果 System.out.println("futureTask.get()未获取到结果"); } } catch (InterruptedException e){ e.printStackTrace(); }catch (Exception e) { e.printStackTrace(); } // 5.关闭线程池 executorService.shutdown(); System.out.println("主线程执行完成"); }}
复制代码



发布于: 刚刚阅读数: 4
用户头像

Yeats_Liao

关注

Hello,World! 2022-10-02 加入

这里更多的是记录个人学习,如果有侵权内容请联系我! 个人邮箱是:yeats_liao@foxmail.com

评论

发布
暂无评论
Java多线程 Future和FutureTask的区别_后端_Yeats_Liao_InfoQ写作社区