如何在运行@Async任务时延迟应用程序关闭？

Question

我有一个异步任务执行器。如何让Spring在所有任务完成之前等待应用程序关闭？

@Bean
public ThreadPoolExecutor singleExecutor() {
    return new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS,
            new ArrayBlockingQueue<>(10),
            new ThreadPoolExecutor.DiscardPolicy());
}


@Service
class MyService {
    @Async("singleExecutor")
    public void runAsync() {
     
    }
} 

Answer 1

org.springframework.scheduling.concurrent.ThreadPoolTaskExec导师类（实现了TaskExec导师接口org.springframework.core.task.）通过以下方法支持请求的功能：

• 设置waitfortaskstocompleteonshutton（）

因此，请考虑迁移bean：

• From:java。util。同时发生的ThreadPoolExecutor
• 致：org。springframework。果心任务TaskExecutor

«迁移bean»示例：

@Bean
public TaskExecutor singleExecutor() {
    final ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(1);
    taskExecutor.setMaxPoolSize(1);
    taskExecutor.setKeepAliveSeconds(0);
    taskExecutor.setQueueCapacity(10);
    taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());
    taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
    taskExecutor.setAwaitTerminationSeconds(300);
    return taskExecutor;
}