首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

获取线程的返回值,基于Callable接口实现多线程

1 为什么要用Callable

前面已经介绍了基于Thread和Runnable两种方法定义线程主体。细心的人可能会发现这么一个问题,那就是不论是哪种方法,我们都不知道线程是什么时候执行结束的。所以又提供了第三种多线程主体定义的形式:实现Callable接口。

2 创建一个实现Callable的对象

我们先创建一个CallableDemo类,并在里面创建一个MyThread3内部类,MyThread3实现Callable接口。实现之后,MyThread3就是一个实现了Callable的一个子类,请注意,callable有一个泛型,这个泛型的数据类型取决议call方法return的数据类型。MyThread3类代码如下图。

MyThread3,添加一个call()方法,代替原来的run方法,编写业务核心。本次线程依然是实现了一个从1到100的报数功能。在报数结束之后,返回线程执行结束的通知。实际业务中,可以返回执行过程统计后得到的数据。

3 创建并启动线程

我们通过new FutureTask的方式创建3个FutureTask对象。把MyThread3作为参数,传入刚创建的FutureTask对象中。由于call方法返回的是String类型,所以FutureTask给到的泛型对应也是String类型,再new三个Thread线程对象,分别把刚才的FutrueTask对象作为参数传入。调用Thread对象的start方法启动。将三个线程启动结束后,我们再调用task.get(),获取线程执行的返回值,效果如下。

从运行的结果来看,成功启动并执行了3个线程,并获取到返回值。

4 类图介绍

更多详情可查看jdk源码。

5 Lambda表达式

Callable是函数式接口,那么我们也可以通过更简洁的代码来实现上面的功能。不多介绍,代码及测试如下。

创建线程的方式很多,如果程序需要线程返回结果,那么就请各位工匠使用Callable接口方式实现线程主体类。如果不需要任何返回,Runnable是非常不错的选择。

有一点请各位注意,task.get()会造成主线程堵塞,所以请先启动准备启动的所有线程,结尾处再去获取各线程的返回值。切记切记。

6 结束语

人人都是程序员,感谢您的阅读,欢迎关注。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20200229A0AHTJ00?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券