这篇文章其实主要是想要讲清楚一个概念,就是Runable和Callable的区别,以及当它们和FutureTask、ExecutorService一起执行的原理。
基本概念
说明:
1、上图中java多线程的实现方案就没什么好说的了,基本上搞java的人都是理解的。
2、其实我始终觉得Thread是一个容器,所以和Runnable和Callable应该不在一个层次的概念,Thread应该是cpu真正调度的实体,这个实体会做什么呢,会执行Runnable和Callable的方法,所以特别不喜欢把这三者放在一起。
基本流程
说明:
1、左边是任务创建过程,右边是任务执行过程。
基本用法
说明:
1、这个截图基本上就是Runnable和Callable和ExecutorService结合一起使用的用法。
2、关键是我比较感兴趣submit内部做了什么事情。
FutureTask创建之Callble对象
说明:
1、在submit一个对象的时候,其实内部是给我们创建了一个FutureTask对象,整个创建过程是层层递进的。
2、FutureTask对象有两个重要属性,一个是callable对象也就是执行对象,一个state,标记这个任务是否完成。
FutureTask创建之Runable
说明:
1、当我们针对Runnable对象创建futureTask的时候内部其实用Callable的适配器包装了一下,然后对外以Callable的对象运行。
2、可以看到call实际上调用的是task的run函数,这个run就不说了吧,线程里面的入口函数。
FutureTask内部属性
说明:
1、几个核心属性,callable就是刚刚所谓的执行对象,outcome最后执行返回的结果,其他整个线程的执行状态流转。
FutureTask任务提交
说明:
1、这个futureTask的提交过程跟我们跟文章《我发现我不懂你了_JUC》其实是一样的,可以自行参考。
2、ExecutorService里面的worker其实真正调用的是run函数,所以我们还需要进一步搞清楚FutureTask是否包含run函数,当然毫无疑问肯定是有的,可以参考下面这个图。
FutureTask任务执行
说明:
1、接上面描述的文字,所以ExecutorService的worker其实真正执行的是Callable对象的call函数并设置回调结果。