7、Callable
线程创建方式 Thread、Runnable、Callable区别：
1、是否有返回值
Runnable 没有返回值，Callable有返回值
2、是否跑出异常
Runnable 没有异常，Callable有异常
3、方法不同， run（），call（）
Runnable 运行的方法是run，Callable运行的方法是call
7.1. Thread与Callable之间的适配类：FutureTask
FutureTask是一个异步运算的任务。FutureTask里面可以传入一个Callable的具体实现类，可以对这个异步运算的任务和结果进行等待、获取，并判断是否已经完成、取消任务等操作。由于FutureTask也是Runnable接口的实现类，所以FutureTask也可以放入线程池中。
Thread创建线程，只能与Runnable有联系，与Callable没有关系，看官方API文档。
Thread怎么创建Callable线程呢？
在设计模式中建立两者之间的关系经常使用适配器，我们去查找jdk官方文档，看能否找到Thread和Callable相互之间有关联的类。
1、查看Runnable官方文档
2、查看Runnable子类
Thread能够引入Runnable，就能引入它的子类，我们看一下它的子类里面哪些有Callable相关的影子。
3、找到Thread与Callable的万能桥：FutureTask
我们在FutureTask类的构造器中找到了Callable。于是我们就可以利用FutureTask来与Callable建立关系。FutureTask成为Thread中万能的桥。
怎么使用呢？看以下示例：
package com.interview.concurrent.futuretask;
import java.util.Arrays;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
/**
* @author DDKK.COM 弟弟快看，程序员编程资料站
* @description 描述:创建线程的方法：
* 1、Thread（Runnable）
* 2、Thread（RunnableFuture）
* 3、Thread（FutureTask）
* @date 2023/2/23 0:55
*/
public class ThreadFutureTask {
public static void main(String[] args) {
MyCallable callable = new MyCallable();
// 适配类
FutureTask task = new FutureTask(callable);
// 执行线程
new Thread(task).start();
// 获取返回值， get()
try {
System.out.println(task.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
class MyCallable implements Callable<String{
@Override
public String call() throws Exception {
System.out.println("我Callable被调用了");
return "callable";
}
}
7.2. Callable有什么优点
Callable 优点：
缓存: 结果缓存！效率提高N倍
结果获取会阻塞：task.get() 获取值的方法一般放到最后，保证程序平稳运行的效率，因为他会阻塞等待结果产生！
package com.interview.concurrent.futuretask;
import java.util.Arrays;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
/**
* @author DDKK.COM 弟弟快看，程序员编程资料站
* @description 描述:创建线程的方法：
* 1、Thread（Runnable）
* 2、Thread（RunnableFuture）
* 3、Thread（FutureTask）
* @date 2023/2/23 0:55
*/
public class ThreadFutureTask {
public static void main(String[] args) {
MyCallable callable = new MyCallable();
// 适配类
FutureTask task = new FutureTask(callable);
/**
* @description:执行线程
* 以下两个线程只会调用一次，为什么呢？
* 结果缓存！，第一个线程执行的结果，已经做了缓存，这样线程的效率会提高N倍
*
*/
new Thread(task,"A").start();
new Thread(task,"B").start();
// 获取返回值， get()
try {
// 细节2：task.get() 获取值的方法一般放到最后，保证程序平稳运行的效率，因为他会阻塞等待结果产生！
System.out.println(task.get());// 获取返回值， get()
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
}
class MyCallable implements Callable<String{
@Override
public String call() throws Exception {
System.out.println("我Callable被调用了");
TimeUnit.SECONDS.sleep(3);
return "callable";
}
}
运行结果如下:
两个线程运行，结果却只输出一次，这就是FutureTask的缓存作用。