定时任务订单上报使用orderThreadPool线程池

pang.jiabao

2 天以前 9d7718b8acf9770d7b9335019b19aeed7320483b

定时任务订单上报使用orderThreadPool线程池

 src/main/java/com/zy/asrs/task/AutoReportingScheduler.java

@@ -8,6 +8,7 @@
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -34,6 +35,7 @@

    //    @Scheduled(cron = "0 0/10 * * * ? ")
    @Scheduled(cron = "0/10 * * * * ? ")
    @Async("orderThreadPool")
    void execute() {
        Config config = configService.selectConfigByCode("AutoReportU8");
        if (config != null && config.getStatus() == 1) {

 src/main/java/com/zy/common/config/ThreadPoolConfig.java

@@ -2,6 +2,7 @@

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

@@ -15,6 +16,7 @@
public class ThreadPoolConfig {

    @Bean(name = "orderThreadPool")
    @Primary
    public ThreadPoolTaskExecutor orderThreadPool() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        int core = Runtime.getRuntime().availableProcessors();