它们俩其实挺有意思,在运行的时候各司其职,Callable产生结果,Future获取结果。
使用步骤如下:
- 创建 Callable 接口的实现类,并实现 call() 方法,该 call() 方法将作为线程执行体,并且有返回值;
- 创建 Callable 实现类的实例,使用 FutureTask 类来包装 Callable 对象,该 FutureTask 对象封装了该 Callable 对象的 call() 方法的返回值;
- 使用 FutureTask 对象作为 Thread 对象的 target 创建并启动新线程;
- 调用 FutureTask 对象的 get() 方法来获得子线程执行结束后的返回值。
接下来通过一个示例来学习这两个对象的使用:
public class Test {public static void main(String[] args) {CallableThreadTest cts = new CallableThreadTest();// 接收FutureTask<Integer> ft = new FutureTask<>(cts);new Thread(ft, "有返回值的线程").start();for (int i = 0; i < 30; i++) {System.out.println( "main" + " 的循环变量i的值:" + i);}try {System.out.println("子线程的返回值:" + ft.get());} catch (Exception e) {e.printStackTrace();}}
}
class CallableThreadTest implements Callable<Integer> {public Integer call() throws Exception {int i = 0;for (; i < 30; i++) {System.out.println(Thread.currentThread().getName() + " " + i);}return i;}
}
运行这段程序你应该可以获取到类似如下结果(每次运行的结果不一致): ... ... main 的循环变量i的值:28 main 的循环变量i的值:29 有返回值的线程 23 有返回值的线程 24 有返回值的线程 25 有返回值的线程 26 有返回值的线程 27 有返回值的线程 28 有返回值的线程 29 子线程的返回值:30
由于输出过长,省略了部分结果,可以发现在最后接收到了子线程的返回值。
在实现Callable接口中,此时不再是run()方法了,而是call()方法,此call()方法作为线程执行体,同时还具有返回值!
细心的你会发现这个结果是call函数的返回值,怎么拿到这个返回值的呢?是通过FutureTask拿到的,使用ft.get()方法即可获得线程的返回值,这就是一个简单的使用Callable和Future的过程了。