Java Callable接口实现细节详解
代码如下
import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; /** * @author lzq * @data 2020/4/30 0030 - 下午 4:02 */ public class Test2 { public static void main(String[] args) throws ExecutionException, InterruptedException { MyThread thread=new MyThread(); FutureTask task = new FutureTask(thread); new Thread(task,"a").start(); new Thread(task,"b").start(); System.out.println(task.get()); } } class MyThread implements Callable<String> { @Override public String call() { System.out.println("实现callable"); return "得到返回值"; } }
执行结果为:
上面是使用Callable接口简单实现多线程,使用这个接口要使用FutrueTask类作为简单的适配类,因为Thread构造方法只能接受Runnable接口参数,下面源码中看出FutrueTask的对象为什么也能作为Runnable型参数传给Thread构造方法
再分析一下结果,可以看到明明启动了a,b两个线程,但是只输出了一个线程的结果,这是因为运行的结果会被缓存,使得线程的执行效率变高。还有一点就是获取线程返回值的get方法可能会产生阻塞,一般放在最后或者使用异步通信来处理。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
相关文章
JAVA环境搭建之MyEclipse10+jdk1.8+tomcat8环境搭建详解
本文详细讲解了MyEclipse10+jdk1.8+tomcat8的JAVA环境搭建方法,希望能帮助到大家2018-10-10解决spring-cloud-config 多服务共享公共配置的问题
这篇文章主要介绍了解决spring-cloud-config 多服务共享公共配置的问题,本文通过多种方法给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-11-11深入研究spring boot集成kafka之spring-kafka底层原理
这篇文章主要深入研究了spring boot集成kafka如何实现spring-kafka的底层原理分析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步2022-02-02
最新评论