資訊專(zhuān)欄INFORMATION COLUMN
摘要：同時(shí)使用框架自己定義的抽象接口來(lái)屏蔽掉底層版本間以及中的線(xiàn)程池和定時(shí)任務(wù)處理的差異。配置文件如下所示完成配置后即可使用此線(xiàn)程池。
1.功能介紹
Spring框架提供了線(xiàn)程池和定時(shí)任務(wù)執(zhí)行的抽象接口：TaskExecutor和TaskScheduler來(lái)支持異步執(zhí)行任務(wù)和定時(shí)執(zhí)行任務(wù)功能。同時(shí)使用框架自己定義的抽象接口來(lái)屏蔽掉底層JDK版本間以及Java EE中的線(xiàn)程池和定時(shí)任務(wù)處理的差異。
另外Spring還支持集成JDK內(nèi)部的定時(shí)器Timer和Quartz Scheduler框架。
TaskExecutor涉及到的相關(guān)類(lèi)圖如下：
TaskExecutor接口源代碼如下所示：
public interface TaskExecutor extends Executor {
/**
* Execute the given {@code task}.
* The call might return immediately if the implementation uses
* an asynchronous execution strategy, or might block in the case
* of synchronous execution.
* @param task the {@code Runnable} to execute (never {@code null})
* @throws TaskRejectedException if the given task was not accepted
*/
@Override
void execute(Runnable task);
}
此接口和Executor幾乎完全一樣，只定義了一個(gè)接收Runnable參數(shù)的方法，據(jù)Spring官方介紹此接口最初是為了在其他組建中使用線(xiàn)程時(shí)，將JKD抽離出來(lái)而設(shè)計(jì)的。在Spring的一些其他組件中比如ApplicationEventMulticaster，Quartz都是使用TaskExecutor來(lái)作為線(xiàn)程池的抽象的。
3.Spring提供的TaskExecutor的實(shí)現(xiàn)類(lèi)org.springframework.core.task.SimpleAsyncTaskExecutor
此實(shí)現(xiàn)支持任務(wù)的異步執(zhí)行，但是此實(shí)現(xiàn)沒(méi)有線(xiàn)程的復(fù)用，每次執(zhí)行一個(gè)提交的任務(wù)時(shí)候都會(huì)新建一個(gè)線(xiàn)程，任務(wù)執(zhí)行完成后會(huì)將線(xiàn)程關(guān)閉，最大并發(fā)數(shù)默認(rèn)是沒(méi)有限制的，但是可以通過(guò)調(diào)用下面的方法來(lái)設(shè)置最大并發(fā)數(shù)。一般使用線(xiàn)程池來(lái)代替此實(shí)現(xiàn)，特別是執(zhí)行一些生命周期很短的任務(wù)的時(shí)候。
public void setConcurrencyLimit(int concurrencyLimit) {
this.concurrencyThrottle.setConcurrencyLimit(concurrencyLimit);
}
Spring還提供了同步任務(wù)執(zhí)行的實(shí)現(xiàn)類(lèi)：
org.springframework.core.task.SyncTaskExecutor
此類(lèi)中只有一個(gè)方法，代碼如下：
@Override
public void execute(Runnable task) {
Assert.notNull(task, "Runnable must not be null");
task.run();
}
此方法中直接調(diào)用傳入的Runable對(duì)象的run方法，因此在執(zhí)行此方法的時(shí)候不會(huì)另外開(kāi)啟新的線(xiàn)程，只是普通的方法調(diào)用，同步執(zhí)行提交的Runable對(duì)象。
Spring有兩個(gè)線(xiàn)程池的實(shí)現(xiàn)類(lèi)，分別為：SimpleThreadPoolTaskExecutor和ThreadPoolTaskExecutor，其中當(dāng)我們有Quarts和非Quarts共享同一個(gè)線(xiàn)程池的需求的時(shí)候使用SimpleThreadPoolTaskExecutor，除了這種情況，我們一般是使用
ThreadPoolTaskExecutor，此實(shí)現(xiàn)可以通過(guò)屬性注入來(lái)配置線(xiàn)程池的相關(guān)配置。 ThreadPoolTaskExecutor中屬性注入的源碼如下：此配置可以在運(yùn)行期修改，代碼中修改過(guò)程使用了同步控制。
/** * Set the ThreadPoolExecutor"s core pool size. * Default is 1. *4.TaskExecutor使用DemoThis setting can be modified at runtime, for example through JMX. */ public void setCorePoolSize(int corePoolSize) { synchronized (this.poolSizeMonitor) { this.corePoolSize = corePoolSize; if (this.threadPoolExecutor != null) { this.threadPoolExecutor.setCorePoolSize(corePoolSize); } } }
首先定義一個(gè)任務(wù)如下所示：
public class DataSimulation implements Runnable{
private HourAverageValueDao hourAverageValueDao;
@Override
public void run() {
Random random = new Random();
AverageValue averageValue = new AverageValue();
averageValue.setAverageVaule(random.nextInt(100));
averageValue.setCreatedTime(new Date());
hourAverageValueDao.insert(averageValue);
}
}
此任務(wù)中產(chǎn)生一個(gè)隨機(jī)數(shù)，并封裝成一個(gè)類(lèi)對(duì)象，并將此數(shù)據(jù)插入到數(shù)據(jù)庫(kù)中。
然后需要定一個(gè)類(lèi)，使用TaskExecutor，代碼如下：
public class DataFacotory {
private TaskExecutor executor;
public TaskExecutor getExecutor() {
return executor;
}
public void setExecutor(TaskExecutor executor) {
this.executor = executor;
}
public void dataFactory(){
for (int i =0; i < 10; i++){
executor.execute(new DataSimulation());
}
}
}
此類(lèi)中定義了TaskExecutor的屬性，并定一個(gè)方法，此方法中提交10個(gè)任務(wù)到TaskExecutor，下面只需配置Spring文件，注入TaskExecutor就可以實(shí)現(xiàn)線(xiàn)程池的使用。配置文件如下所示：
完成配置后即可使用此線(xiàn)程池。Spring提供的線(xiàn)程池可以通過(guò)配置文件配置線(xiàn)程池的配置，相比JDk自帶的線(xiàn)程池是一個(gè)很大的優(yōu)勢(shì)。
5.為什么使用線(xiàn)程池1.通過(guò)使用線(xiàn)程池來(lái)實(shí)現(xiàn)線(xiàn)程的復(fù)用，減少線(xiàn)程創(chuàng)建和銷(xiāo)毀的開(kāi)銷(xiāo)
2.將執(zhí)行線(xiàn)程的任務(wù)交給線(xiàn)程池來(lái)操作，一定意義上實(shí)現(xiàn)了解耦
3.使用線(xiàn)程池可以控制任務(wù)的最大并發(fā)數(shù)目，這個(gè)在防止內(nèi)存溢出以及并發(fā)優(yōu)化方面有很重要的作用。
TaskScheduler接口源代碼如下：
public interface TaskScheduler {
//通過(guò)觸發(fā)器來(lái)決定task是否執(zhí)行
ScheduledFuture schedule(Runnable task, Trigger trigger);
//在starttime的時(shí)候執(zhí)行一次
ScheduledFuture schedule(Runnable task, Date startTime);
從starttime開(kāi)始每個(gè)period時(shí)間段執(zhí)行一次task
ScheduledFuture scheduleAtFixedRate(Runnable task, Date startTime, long period);
每隔period執(zhí)行一次
ScheduledFuture scheduleAtFixedRate(Runnable task, long period);
從startTime開(kāi)始每隔delay長(zhǎng)時(shí)間執(zhí)行一次
ScheduledFuture scheduleWithFixedDelay(Runnable task, Date startTime, long delay);
每隔delay時(shí)間執(zhí)行一次
ScheduledFuture scheduleWithFixedDelay(Runnable task, long delay);
}
指定開(kāi)始時(shí)間的接口，如果時(shí)間已經(jīng)是過(guò)去的某一時(shí)間點(diǎn)，則此任務(wù)會(huì)馬上執(zhí)行一次。以上幾種執(zhí)行方式傳入Trigger的方式是用的最多的，Trigger接口中只定義了一個(gè)方法：
Date nextExecutionTime(TriggerContext triggerContext);
其中參數(shù)類(lèi)型TriggerContext的定義如下：
public interface TriggerContext {
/**
* Return the last scheduled execution time of the task,
* or {@code null} if not scheduled before.
*/
Date lastScheduledExecutionTime();
/**
* Return the last actual execution time of the task,
* or {@code null} if not scheduled before.
*/
Date lastActualExecutionTime();
/**
* Return the last completion time of the task,
* or {@code null} if not scheduled before.
*/
Date lastCompletionTime();
}
提供了獲取上一次任務(wù)執(zhí)行信息的接口。我們通過(guò)實(shí)現(xiàn)Trigger接口可以實(shí)現(xiàn)自定義觸發(fā)器來(lái)執(zhí)行執(zhí)行task。當(dāng)然Spring也提供了兩個(gè)默認(rèn)的實(shí)現(xiàn)類(lèi)：PeriodicTrigger和CronTrigger。
7.TaskScheduler定時(shí)任務(wù)Demo首先在Spring配置文件中啟用注解配置如下：
