JUC线程池（一）: FutureTask使用

小半 • 2022年12月27日下午2:01 • 后端开发 • 阅读 84

Future 表示了一个任务的生命周期，是一个可取消的异步操作，它在未来的某个时刻完成，并提供对其结果的访问。

并发包中许多异步任务类都继承自Future，其中最典型的就是 FutureTask。

一. FutureTask简介

FutureTask常用来封装 Callable 和 Runnable ，也可以作为一个任务提交到线程池中执行。

Future的线程安全有CAS保证。

FutureTask实现了Future的基础功能，如获取任务执行结果（get）和取消任务（cancel）等。如果任务尚未完成获取任务执行结果时会堵塞。

二. 使用案例

通过FutureTask封装Callable实现，运行时可以获取线程的状态（是否运行完）、也可以取消任务，运行完成可以获取结果，对于线程运行可以有以下两种方式：

线程池运行futureTask
Thread线程运行futureTask


public class CallDemo {

    public static void main(String[] args) {


        /**
         *
         * 方式1 : 线程池运行futureTask（futureTask包装的callable接口，futureTask可以拿到执行结果）。
         *
         * FutureTask + ExecutorService:
         *
         * ExecutorService executor = Executors.newCachedThreadPool();
         * Task task = new Task();
         * FutureTask<Integer> futureTask = new FutureTask<Integer>(task);
         * executor.submit(futureTask);
         * executor.shutdown();
         */

        /**
         * 方式2 : 线程运行futureTask
         * FutureTask + Thread
         */

        // 2. 新建FutureTask,需要一个实现了Callable接口的类的实例作为构造函数参数
        FutureTask<Integer> futureTask = new FutureTask<Integer>(new MyTask());
        // 3. 新建Thread对象并启动
        Thread thread = new Thread(futureTask);
        thread.setName("Task thread");
        thread.start();

        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.println("Thread [" + Thread.currentThread().getName() + "] is running");

        // 4. 调用isDone()判断任务是否结束
        if (!futureTask.isDone()) {
            System.out.println("Task is not done");
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        int result = 0;
        try {
            // 5. 调用get()方法获取任务结果,如果任务没有执行完成则阻塞等待
            result = futureTask.get();
        } catch (Exception e) {
            e.printStackTrace();
        }

        System.out.println("result is " + result);

    }

    // 1. 继承Callable接口,实现call()方法,泛型参数为要返回的类型
    static class MyTask implements Callable<Integer> {

        @Override
        public Integer call() throws Exception {
            System.out.println("Thread [" + Thread.currentThread().getName() + "] is running");
            int result = 0;
            for (int i = 0; i < 100; ++i) {
                result += i;
            }

            Thread.sleep(3000);
            return result;
        }
    }
}