Java多线程详解（七）------Callable接口介绍

一、与runnable接口对比

 创建新类MyThread实现runnable接口
class MyThread implements Runnable{
 @Override
 public void run() {
 
 }
}
新类MyThread2实现callable接口
class MyThread2 implements Callable<Integer>{
 @Override
 public Integer call() throws Exception {
  return 200;
 } 
}
 面试题:callable接口与runnable接口的区别？
 
 答：（1）是否有返回值
       （2）是否抛异常
       （3）落地方法不一样，一个是run，一个是call
 
 
 
 

二、如何使用

 

 不可行，因为：thread类的构造方法根本没有Callable

FutureTask<Integer> ft = new FutureTask<Integer>(new MyThread());
new Thread(ft, "AA").start();

运行成功后如何获得返回值？

 ft.get();

三、FutureTask

是什么

未来的任务，用它就干一件事，异步调用
main方法就像一个冰糖葫芦，一个个方法由main串起来。
但解决不了一个问题：正常调用挂起堵塞问题

在主线程中需要执行比较耗时的操作时，但又不想阻塞主线程时，可以把这些作业交给Future对象在后台完成，
当主线程将来需要时，就可以通过Future对象获得后台作业的计算结果或者执行状态。

一般FutureTask多用于耗时的计算，主线程可以在完成自己的任务后，再去获取结果。

仅在计算完成时才能检索结果；如果计算尚未完成，则阻塞 get 方法。一旦计算完成，
就不能再重新开始或取消计算。get方法而获取结果只有在计算完成时获取，否则会一直阻塞直到任务转入完成状态，
然后会返回结果或者抛出异常。

只计算一次
get方法放到最后

代码：

package com.study.callable;


import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;

class MyThread implements Runnable {
    @Override
    public void run() {
    }
}

class MyThread2 implements Callable<Integer> {
    @Override
    public Integer call() throws Exception {
        System.out.println(Thread.currentThread().getName() + " come in callable");
        return 200;
    }
}

public class CallableDemo {
    public static void main(String[] args) throws Exception {
//        FutureTask<Integer> futureTask = new FutureTask<>(new MyThread2());
//        new Thread(futureTask,"zhang3").start();//传入futureTask对象
//        System.out.println(futureTask.get());
//
        FutureTask<Integer> ft1 = new FutureTask(() -> {
            System.out.println(Thread.currentThread().getName() + " come in callable");
            TimeUnit.SECONDS.sleep(4);
            return 1024;
        });
        FutureTask<Integer> ft2 = new FutureTask(() -> {
            System.out.println(Thread.currentThread().getName() + " come in callable");
            TimeUnit.SECONDS.sleep(4);
            return 2048;
        });
        //启动线程
        new Thread(ft1, "zhang3").start();
        new Thread(ft2, "li4").start();

        System.out.println(ft1.get());
        System.out.println(ft2.get());

        /**
         *
         *
         在主线程中需要执行比较耗时的操作时，但又不想阻塞主线程时，可以把这些作业交给Future对象在后台完成，
         当主线程将来需要时，就可以通过Future对象获得后台作业的计算结果或者执行状态。

         一般FutureTask多用于耗时的计算，主线程可以在完成自己的任务后，再去获取结果。

         仅在计算完成时才能检索结果；如果计算尚未完成，则阻塞 get 方法。一旦计算完成，
         就不能再重新开始或取消计算。get方法而获取结果只有在计算完成时获取，否则会一直阻塞直到任务转入完成状态，
         然后会返回结果或者抛出异常。

         只计算一次
         get方法放到最后
         */
    }
}