spring task 动态配置并支持多线程方案

Question

使用 taskRegistrar.setScheduler(taskExecutor()); 设置线程池

直接贴代码：

package com.pt.config;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

@Configuration
@EnableScheduling
public class DynamicTask implements SchedulingConfigurer{
private static Logger log = LoggerFactory.getLogger(DynamicTask.class);

static List<PtCronTask> totalTask = new ArrayList<>();
static {
    PtCronTask newTask = new PtCronTask();
    
    //添加测试数据
    newTask.setCronString("0/60 * * * * ?");
    newTask.setHandleServe("Service1");
    totalTask.add(newTask);
    
    newTask = new PtCronTask();
    newTask.setCronString("0/5 * * * * ?");
    newTask.setHandleServe("Service2");
    totalTask.add(newTask);
}

@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    // TODO Auto-generated method stub
    taskRegistrar.setScheduler(taskExecutor());
     int index = 0;
    for( PtCronTask newTask : totalTask ) {
         log.info(""+newTask.getCronString());
         index++;
         taskRegistrar.addCronTask(getRunnable(index), newTask.getCronString());
       
    }
}

@Bean
public Executor taskExecutor() {
    return Executors.newScheduledThreadPool(20);        //指定线程池大小
}


private Runnable getRunnable(Integer count) {
    //这边推荐设计数据库存储方法名，根据反射来取出方法java
    // 【例如存入一个为test01的字段,java写一个test01的方法。根据反射来创建出Runnable来执行方法】
    if (count == 1) {
        return new Runnable() {
            @Override
            public void run() {
                System.out.println("数据库id为1===>任务1  "+ Thread.currentThread().getName() + " " +System.currentTimeMillis()/1000);
                try {
                    Thread.sleep(1000* 100);
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        };
    }else if (count == 2) {
        return new Runnable() {
            @Override
            public void run() {
                System.out.println("数据库id为2===>任务2 "+ Thread.currentThread().getName() + " "  +System.currentTimeMillis()/1000);
            }
        };
    }else {
        return new Runnable() {
            @Override
            public void run() {
                System.out.println("默认执行");
            }
        };
    }
}


public static class PtCronTask{
    private String cronString;
    private String handleServe;
    public String getCronString() {
        return cronString;
    }
    public void setCronString(String cronString) {
        this.cronString = cronString;
    }
    public String getHandleServe() {
        return handleServe;
    }
    public void setHandleServe(String handleServe) {
        this.handleServe = handleServe;
    }
    
}

}