7_Callable&Future接口

Posted root_zhb

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了7_Callable&Future接口相关的知识,希望对你有一定的参考价值。

Callable&Future接口

1、简介

  1. Runnable和Callable区别

    • Runnable无返回值,Callable可以使线程返回结果。
    • run()不会发生异常,call()方法可以引发异常
    • Callable不能直接替换 Runnable,因为 Thread 类的构造方法根本没有 Callable
  2. Future 接口

    //用于停止任务:如果尚未启动,它将停止任务。如果已启动,则仅 mayInterrupt 为 true 时才会中断任务。
    public boolean cancel(boolean mayInterrupt)
    //用于获取任务的结果。抛出 InterruptedException,ExecutionException
    //如果任务完成,它将立即返回结果,否则将等待任务完成,然后返回结果
    public Object get()
    //如果任务完成,则返回 true,否则返回 false
    public boolean isDone()
    
  3. FutureTask

    • FutureTask实现了 Runnable 和 Future 接口
    • 使用 Callable 创建线程:①.为 FutureTask 构造函数提供 Callable对象, ②为Thread 构造函数提供 FutureTask 对象

2、代码

//Runnable创建线程
class MyThread1 implements Runnable{
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "线程进入了 run 方法");
    }
}

//Callable创建线程
class MyThread2 implements Callable{
    @Override
    public Integer call(){
        System.out.println(Thread.currentThread().getName() + "线程进入了 call 方法");
        return 1234;
    }
}

public class ThreadTest {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        //Runnable接口
        new Thread(new MyThread1(),"AA").start();

        //Callable接口,报错,因为Thread对象只接受Runnable接口实现类。
//        new Thread(new MyThread2(),"BB").start();

       /*
       找一个类,既和Runnable有关系,又和Callable也有关系
       Runnable接口有实现类 FutureTask, FutureTask构造可以传递Callable
        */
        //FutureTask
        FutureTask<Integer> futureTask=new FutureTask<>(new MyThread2());

        //lambda表达式
        FutureTask<Integer> futureTask2=new FutureTask<>(()->{
            System.out.println(Thread.currentThread().getName() + "线程进入了 call 方法");
            return 1024;
        });

        new Thread(futureTask,"BB").start();

        //FutureTask 执行完之后可以随时获取到这个线程的返回值而不用再去执行一次(不用call了,直接用现成的结果)
        Integer integer = futureTask.get();
        System.out.println(integer);
        Integer integer2 = futureTask.get();
        System.out.println(integer2);
    }
}

3、总结

  1. 要创建线程,需要 Runnable。为了获得结果,需要 Future。
  2. 在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给 Future 对象在后台完成, 当主线程将来需要时,就可以通过 Future对象获得后台作业的计算结果或者执行状态
  3. 一般 FutureTask 多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果
  4. 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞 get 方法。一旦计算完成,就不能再重新开始或取消计算。get 方法获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常。
  5. 只计算一次

以上是关于7_Callable&Future接口的主要内容,如果未能解决你的问题,请参考以下文章

多线程-Callable&Future

Callable 和 Future接口 学习

Callable和Future用法示例

Java Callable接口与Future接口的两种使用方式

Callable/Future

Callable与Future