SpringBoot执行异步任务Async介绍

@EnableAsync
@SpringBootApplication
public class AsycnDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(AsycnDemoApplication.class, args);
    }
}

@Component
public class AsyncComponent {
}

@Component
public class AsyncComponent {
    @Async
    public void async(String str){
        System.out.println("输入的内容是" + str + "，异步任务正在休眠5秒..");
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            System.out.println("休眠失败");
        }
        System.out.println("输入的内容是" + str + ",异步任务执行结束");
    }
}

@Component
public class LineRunner implements CommandLineRunner {
    @Autowired
    private AsyncComponent asyncComponent;

    @Override
    public void run(String... args) throws Exception {
        System.out.println("主线程开始");
        asyncComponent.async("今天不上班，好耶");
        asyncComponent.selfAsync();
        System.out.println("主线程结束");
    }
}

@Configuration
public class ExecutorsAsyncConfig {
    @Bean(name = "asyncConfig")
    public Executor asyncConfig(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //设置核心线程数
        executor.setCorePoolSize(5);
        //设置最大线程数
        executor.setMaxPoolSize(50);
        //设置缓存的队列
        executor.setQueueCapacity(1000);
        //设置空闲线程的超时时间
        executor.setKeepAliveSeconds(1000 * 5);
        //设置线程名称的前缀
        executor.setThreadNamePrefix("async-config-");
        executor.initialize();
        return executor;
    }
}

@Async("asyncConfig")
public void selfAsync(){
    System.out.println("我是自定义异步线程，线程池名称:" + Thread.currentThread().getName());
    try {
        TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {
        System.out.println("休眠失败");
    }
    System.out.println("自定义异步线程休眠结束");
}

asyncComponent.selfAsync();