返回

Java多线程 Future和FutureTask的区别

发布时间:2023-11-12 05:52:53 86

(目录)

一、说明

Future和FutureTask的关系

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

使用区别

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

二、理解

Future

  • java.util.concurrent包下Future接口,对RunnableCallable对象执行任务完成后获取执行结果
public interface Future {
    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接口,可实现Runnable接口执行线程,也可实现Future接口获取执行结果
public class FutureTask implements RunnableFuture {
	……
}
  • RunnableFuture接口继承Runnable
public interface RunnableFuture extends Runnable, Future {
    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("主线程执行完成");
    }
}

在这里插入图片描述

特别声明:以上内容(图片及文字)均为互联网收集或者用户上传发布,本站仅提供信息存储服务!如有侵权或有涉及法律问题请联系我们。
举报
评论区(0)
按点赞数排序
用户头像
精选文章
thumb 中国研究员首次曝光美国国安局顶级后门—“方程式组织”
thumb 俄乌线上战争,网络攻击弥漫着数字硝烟
thumb 从网络安全角度了解俄罗斯入侵乌克兰的相关事件时间线