Java使用Callable和Future创建线程操作示例

Java使用Callable和Future创建线程操作示例

本文实例讲述了java使用Callable和Future创建线程操作。分享给大家供大家参考，具体如下：

一 点睛

从Java 5开始，Java提供了Callable接口，该接口是Runnable接口的增强版，Callable接口提供了一个call()方法，可以看作是线程的执行体，但call()方法比run()方法更强大。

call()方法可以有返回值。

call()方法可以声明抛出异常。

创建并启动线程的步骤如下：

1 创建Callable接口的实现类，并实现call()方法，该call()方法将作为该线程的执行体，且该call()方法有返回值，再创建Callable的实例。从Java 8开始，可以直接使用Lamda表达式创建Callable对象。

2 使用FutureTask类来包装Callable对象，该FutureTask对象封装了该Callable对象的call()方法的返回值。

3 使用FutureTask对象作为Thread对象的target创建并启动新线程。

4 调用FutureTask对象的get()方法来获得子线程执行结束后的返回值。

二 代码

public class ThirdThread

{

public static void main(String[] args)

{

// 创建Callable对象

ThirdThread rt = new ThirdThread();

// 先使用Lambda表达式创建Callable对象

// 使用FutureTask来包装Callable对象

FutureTask task = new FutureTask((Callable)() -> {

int i = 0;

for ( ; i < 1http://00 ; i++ )

{

System.out.println(Thread.currentThread().getName()

+ " 的循环变量i的值：" + i);

}

// call()方法可以有返回值

return i;

});

for (int i = 0 ; i < 100 ; i++)

{

System.out.println(Thread.currentThread().getName()

+ " 的循环变量i的值：" + i);

if (i == 20)

{

// 实质还是以Callable对象来创建、并启动线程

new Thread(task , "有返回值的线程").start();

}

}

try

{

// 获取线程返回值

System.out.println("子线程的返回值：" + task.get());

}

catch (Exception ex)

{

ex.printStackTrace();

}

}

}

三 运行

main 的循环变量i的值：98

main 的循环变量i的值：99

有返回值的线程 的循环变量i的值：23

有返回值的线程 的循环变量i的值：24

有返回值的线程 的循环变量i的值：25

......

有返回值的线程 的循环变量i的值：94

有返回值的线程 的循环变量i的值：95

有返回值的线程 的循环变量i的值：96

有返回值的线程 的循环变量i的值：97

有返回值的线程 的循环变量i的值：98

有返回值的线程 的循环变量i的值：99

子线程的返回值：100

四 说明

程序先使用使用Lamda表达式创建一个Callable对象，然后将该实例包装成一个FutureTask对象。主线程中当循环变量i等于20时，程序启动以FutrueTask对象为target的线程。程序最后调用FutrueTask对象的get()方法来返回call()方法的返回值——该方法将导致主线程被阻塞,直到call()方法结束并返回为止。

更多java相关内容感兴趣的读者可查看本站专题：《Java进程与线程操作技巧总结》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。