今天在梳理业务流程逻辑时发现下面这行代码:

   其中代码中的poolTask就是

org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor:这是spring提供的线程池,只需要我们在配置文件中配置就好.

<bean id="testThreadPoolTaskExecutor"
		class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
		<!-- 核心线程数，默认为1 -->
		<property name="corePoolSize" value="5"  />
		<!-- 最大线程数，默认为Integer.MAX_VALUE -->
		<property name="maxPoolSize" value="10" />
		<!-- 队列最大长度，一般需要设置值>=notifyScheduledMainExecutor.maxNum；默认为Integer.MAX_VALUE -->
		<property name="queueCapacity" value="25" />
		<!-- 线程池维护线程所允许的空闲时间，默认为60s -->
		<property name="keepAliveSeconds" value="60000" />
	</bean>

这个配置简单我就不再赘述了.

我就发现了submit()这个方法,于是就决定一探究竟进到方法发现如图:

ThreadPoolTaskExecutor.的内部submit方法有重载,两个方法的参数分别是:Runnable , Callable<T>  而我今天调用的就是参数为Callable<T>的方法;

可以看到首先调用的一个ThreadPoolTaskExecutor的内部方法:getThreadPoolExecutor() 接着看;

该方法返回了它的threadPoolExecutor;

可以看到spring提供的线程池中封装了java的ThreadPoolExecutor(java.util.concurrent.ThreadPoolExecutor);

而ThreadPoolExecutor继承了AbstractExecutorService实现了ExecutorService接口,接下来调用的是AbstractExecutorService的

submit(CallAble<T> task) 方法;

方法内首先调用内部方法进行了new操作,

得到一个RunnableFuture<T>对象调用了execute方法,然后就将RunnableFuture<T>对象返回了

返回这个对象有什么用呢?

返回的实际是FutureTask<T>对象,FutureTask<T>实现了

我们就可以调用FutureTask<T>实现的get方法得到线程是否正常等其他操作.

支路

我们回到在调用AbstractExecutorService.submit(Callable<T> task)的时候,下面一行调用了execute方法.

execute方法AbstractExecutorService内部是没有的,

这个方法是Executor的接口我们已经知道 AbstractExecutorService 只是实现了 ExecutorService那么这个方法是哪来的?

没错ExecutorService的父接口就是Executor.Executor内部只有一个抽象方法.

而传的对象类型是Runnable,我们同样可以看到RunnableFuture<T>的父接口就有Runnable,哈哈我们快到终点了

既然我们已经知道execute方法AbstractExecutorService内部是没有的,那就在ThreadPoolExecutor找,嘿嘿果然在