public interface TaskExecutor extends Executor {

 /**
  * Execute the given {@code task}.
  * <p>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);

}

org.springframework.core.task.SimpleAsyncTaskExecutor

public void setConcurrencyLimit(int concurrencyLimit) {
  this.concurrencyThrottle.setConcurrencyLimit(concurrencyLimit);
 }

 org.springframework.core.task.SyncTaskExecutor

@Override
 public void execute(Runnable task) {
  Assert.notNull(task, "Runnable must not be null");
  task.run();
 }

/**
 * Set the ThreadPoolExecutor's core pool size.
 * Default is 1.
 * <p><b>This setting can be modified at runtime, for example through JMX.</b>
 */
public void setCorePoolSize(int corePoolSize) {
 synchronized (this.poolSizeMonitor) {
  this.corePoolSize = corePoolSize;
  if (this.threadPoolExecutor != null) {
   this.threadPoolExecutor.setCorePoolSize(corePoolSize);
  }
 }
}

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);

 }
}

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());
  }
 }
}

<bean id = "taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
  <property name="corePoolSize" value = "5"></property>
  <property name = "maxPoolSize" value="10"></property>
  <property name="queueCapacity" value="25"></property>
 </bean>

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);
}

Date nextExecutionTime(TriggerContext triggerContext);

public interface TriggerContext {

/**
 * Return the last <i>scheduled</i> execution time of the task,
 * or {@code null} if not scheduled before.
 */
Date lastScheduledExecutionTime();

/**
 * Return the last <i>actual</i> 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();

}

<task:annotation-driven scheduler="myScheduler"/> //指定scheduler屬性是可選項(xiàng)，不添加也可以正常使用
<task:scheduler id="myScheduler" pool-size="10"/>

@Component
public class SchedulerPoolTest {

 @Scheduled(cron = "0 * * * * ?")
 public void task1(){
  System.out.println("test");
  Thread thread = Thread.currentThread();
  System.out.println("ThreadName:" + thread.getName() + ",id:" + thread.getId() + ",group:" + thread.getThreadGroup());

 }

 @Scheduled(fixedDelay = 5000)
 public void task2(){
  System.out.println("test");
  Thread thread = Thread.currentThread();
  System.out.println("ThreadName:" + thread.getName() + ",id:" + thread.getId() + ",group:" + thread.getThreadGroup());

 }

}

<context:component-scan base-package="com.zjut.task" />

<context-param>
 <param-name>contextConfigLocation</param-name>
 <param-value>classpath*:spring-task.xml</param-value>
 </context-param>

 <listener>
 <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
 </listener>

{秒} {分} {時(shí)} {日} {月} {周}

字段名     允許的值      允許的特殊字符 
秒     0-59       , - * / 
分     0-59       , - * / 
小時(shí)     0-23       , - * / 
日     1-31       , - * ? / L W C 
月     1-12 or JAN-DEC     , - * / 
周幾     1-7 or SUN-SAT     , - * ? / L C #

"0 10,44 14 ? 3 WED" 每年三月的星期三的下午2:10和2:44觸發(fā)
"0 0/5 14,18 * * ?" 在每天下午2點(diǎn)到2:55期間和下午6點(diǎn)到6:55期間的每5分鐘觸發(fā)
"15-30/5 * * * * ?" 每分鐘的15秒到30秒之間開(kāi)始觸發(fā)，每隔5秒觸發(fā)一次
"0 15 10 ? * 5#3" 每個(gè)月第三周的星期四的10點(diǎn)15分0秒觸發(fā)任務(wù)