Java Spring的调度程序中的异步任务

Question

我目前在春季应用程序中有一个计划的任务。

但是，这种逻辑的两个部分非常耗时，我想知道是否有一种使这两个部分异步的方法，以免干扰执行逻辑的时间。

我需要执行如下的逻辑。

@Scheduled(fixedDelay = 10000)
    public void startAuction() throws Exception {
        List<SchGoodsAuctionStartListRes> list = schedulerService.schGoodsAuctionStartList();

        for (SchGoodsAuctionStartListRes item : list) {
            schedulerService.schGoodsAuctionStart(item);

            // 1st time consuming block that needs async
            PushInfo pushInfo = pushMapper.pushGoodsSeller(item.getGoodsIdx());
            pushInfo.setTitle("Start");
            pushInfo.setBody("[" + pushInfo.getBrand() + "] started.");
            pushInfo.setPushGrp("001");
            pushInfo.setPushCode("003");
            fcmPushUtil.sendPush(pushInfo);

            // 2nd time consuming block that needs async
            List<PushInfo> pushInfos = pushMapper.pushGoodsAuctionAll(item.getIdx());
            for (PushInfo pushInfoItem : pushInfos) {
                pushInfoItem.setTitle("\uD83D\uDD14 open");
                pushInfoItem.setBody("[" + pushInfo.getBrand() + "] started. \uD83D\uDC5C");
                pushInfoItem.setPushGrp("002");
                pushInfoItem.setPushCode("008");
                fcmPushUtil.sendPush(pushInfoItem);
            }

        }
    }

从我的理解来看，调度程序已经异步执行逻辑，我想知道是否有任何方法可以使这两个块异步使其在执行此逻辑时不会导致延迟。

Answer 1

您可以在这里采用几种方法。

默认情况下为Spring的计划任务配置线程池执行程序，

Spring使用单线程执行程序来执行计划的任务，这意味着即使您有多个@scheduled任务> 任务或在上一个任务触发之前执行的另一个执行完成后，他们都必须在队列中等待。

您可以配置自己的执行程序，以通过春季计划使用。看看 @EnablesCheduling ，这对这个主题非常详尽。

要配置executorService用于计划任务的使用足以定义bean：

@Bean
public TaskScheduler  taskScheduler() {
    ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
    threadPoolTaskScheduler.setPoolSize(8);
    threadPoolTaskScheduler.setThreadNamePrefix("task-scheduler");
    return threadPoolTaskScheduler;
}

此外，如果您使用Spring boot，可以使用属性文件：

spring.task.scheduling.pool.size=8

执行计划的任务

既可以执行计划的任务，则可以不断地执行计划的任务。春季的@ASYNC注释（并确保@enableasync在您的配置中的某个地方。这将使您的任务在后台线程上执行，释放调度线程

@EnableAsync
public class ScheduledAsyncTask {

    @Async
    @Scheduled(fixedRate = 10000)
    public void scheduleFixedRateTaskAsync() throws InterruptedException {
        // your task logic ...
    }
}

。 最终，您可以使用单独

的executorService来运行该任务的昂贵部分，而不是使用该执行程序，而不是用于任务调度的一部分。 Spring用来将任务安排到最低的线程上的执行，从而启动下一个执行。

public class ScheduledAsyncTask implements DisposableBean {

    private final ExecutorService executorService = Executors.newFixedThreadPool(4);

    @Scheduled(fixedRate = 10000)
    public void scheduleFixedRateTaskAsync() throws InterruptedException {
        executorService.submit(() -> {
            // Expensive calculations ...
        });
    }

    @Override
    public void destroy() {
        executorService.shutdown();
    }
}