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 结束语
人人都是程序员,感谢您的阅读,欢迎关注。
领取专属 10元无门槛券
私享最新 技术干货