java常用的线程池

线程池

ThreadPoolTaskExecutor是一种基于Springframework的常用线程池，包含了java.util.concurrent的ThreadPoolExecutor（非继承）。

它有以下几个常用的参数

corePoolSize

核心池数量，即线程池在初始化后，维护的线程数。

queueCapacity

维护的task队列长度，当submit的数量超过corePoolSize时，将task置入该队列中，等待核心池出现空闲线程。

maxPoolSize

最大池数量，当queueCapacity中放满后，将开启新线程直到抵达最大池数量。

keepAliveSeconds

线程池中，“超额”线程所允许的空闲时间。即当线程数超过核心池大小后，若有线程长时间出于idle状态，超过该时间将被回收。

rejectedExecutionHandler

当task队列满，线程池数量达到最大值时，再提交task将会导致拒绝。拒绝行为由此属性给出。（其实是ThreadPoolExecutor的属性）

拒绝行为分为四种：

ThreadPoolExecutor.AbortPolicy：默认值，抛出RejectedExecutionException异常。

ThreadPoolExecutor.CallerRunsPolicy：调用线程池的线程将执行此task，可以有效地减缓task被提交的速度（因为提交task的线程被用于执行task了）。

ThreadPoolExecutor.DiscardPolicy：将新提交的task丢弃。

ThreadPoolExecutor.DiscardOldestPolicy：如果executor未关闭，则删除task队列头部的任务，然后重试execute

在使用Spring加载时，配置文件如下：

<bean id="someThreadPool" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
<property name="corePoolSize" value="4"/>
<property name="maxPoolSize" value="6"/>
<property name="queueCapacity" value="1000"/>
<property name="keepAliveSeconds" value="100"/>
<property name="rejectedExecutionHandler">
<bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />
</property>
</bean>

通过someThreadPool.submit(new Runnable())或者someThreadPool.submit(new Callable())将线程提交给线程池执行。
submit方法会返回Future对象。如果想获取线程执行结果，需要使用callable作为submit的对象，则可以用Future获取线程执行结果(Future.get())。
可以调用shutdown()来关闭线程池。