文章目录
- 获得线程的第三种方式 : Callable接口
- 1. 前言
- 1. 获得多线程的方法几种?
- 2. 以下两种获得线程的方式的异同
- 2. 使用
- 1. 重写 call 方法
- 2.创建线程
- 3.获取返回值
- 3. 原理
- 1. 简述
- 2. 解释
- 3. 结论
获得线程的第三种方式 : Callable接口
1. 前言
1. 获得多线程的方法几种?
- 答:
- 传统的是继承thread类和实现runnable接口
- java5以后又有实现callable接口和java的线程池获得
2. 以下两种获得线程的方式的异同
class MyThread1 implements Runnable{@Overridepublic void run() {}
}
class MyThread2 implements Callable<Integer>{@Overridepublic Integer call() throws Exception {return null;}
}
- 答:
- 两种方式重写的方法不同,Runnable -> run;Callable -> call
- 是否有返回值,Runnable -> 没有(可定义的返回值类型);Callable -> 有
- 是否抛异常,Runnable -> 不抛;Callable -> 抛
2. 使用
1. 重写 call 方法
class MyThread implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("==== 进入 ====");return 1024;}
}
2.创建线程
- 之前 Runable 接口创建线程使用的是 new Thread(Runnable 接口的实现, name).start(),但是查找 jdk 并没有一个参数是 Callable 的构造方法
- 所以就需要迂回一下,需要传入一个 Callable 接口的实现,但只有 Runnable 作为参数的构造方法,那就要找到一个其他的实现类和 Callable 、Runnable 都有关系
- 这像:想认识一个不认识的同学,我可以找中间人介绍,利用java多态,一个类可以实现多个接口
- 按照以上思路就找到了一个类 —— FutureTask,它即实现了 Runnable 接口,又有一个 Callable 作为参数的构造方法
public static void main(String[] args) {// 调用线程,MyThread 类上面写过FutureTask futureTask = new FutureTask(new MyThread());new Thread(futureTask,"Thread_A").start();}
3.获取返回值
public class JUC06_Callable {public static void main(String[] args) throws ExecutionException, InterruptedException {// 调用线程// 创建对象FutureTask futureTask = new FutureTask(new MyThread());// 表达式
// FutureTask futureTask = new FutureTask(
// () -> {System.out.println("==== 进入 ====");
// return 1024;});new Thread(futureTask,"Thread_A").start();// 获得返回值System.out.println(futureTask.get());}
}
// Callable 后的泛型写什么类型,就返回什么类型
class MyThread implements Callable<Integer>{@Overridepublic Integer call() throws Exception {System.out.println("==== 进入 ====");return 1024;}
}
3. 原理
1. 简述
-
FutureTask (未来的任务),用它就干一件事,异步调用
-
main方法就像一个冰糖葫芦,一个个方法由main串起来。
-
但解决不了一个问题:正常调用挂起堵塞问题
-
例子:
- 老师上着课,口渴了,去买水不合适,讲课线程继续,我可以单起个线程找班长帮忙买水,
水买回来了放桌上,我需要的时候再去get。 - 4个同学,A算1+20,B算21+30,C算31*到40,D算41+50,是不是C的计算量有点大啊,
FutureTask单起个线程给C计算,我先汇总ABD,最后等C计算完了再汇总C,拿到最终结果 - 高考:会做的先做,不会的放在后面做
- 老师上着课,口渴了,去买水不合适,讲课线程继续,我可以单起个线程找班长帮忙买水,
2. 解释
- 在主线程中需要执行比较耗时的操作时,但又不想阻塞主线程时,可以把这些作业交给 Future 对象在后台完成
- 当主线程将来需要时,就可以通过 Future 对象获得后台作业的计算结果或者执行状态。
- 一般 FutureTask 多用于耗时的计算,主线程可以在完成自己的任务后,再去获取结果。
- 仅在计算完成时才能检索结果;如果计算尚未完成,则阻塞 get 方法,不会执行主线程后面的任务。
- 一旦计算完成,就不能再重新开始或取消计算。
- get 方法获取结果只有在计算完成时获取,否则会一直阻塞直到任务转入完成状态,然后会返回结果或者抛出异常。
- 第二次调用同一个 FutureTask 线程,不会执行,因为第一次执行完后,就把结果存入缓存后面再掉,就直接从缓存读取
3. 结论
- 同一个 FutureTask 只会只调用一次
- get方法放到最后