@EnableAsync
@Configuration
public class AsyncConfiguration {
    //定義線程池
    @Bean("threadPool1") // bean的名稱，線程池的bean的名字，不是創(chuàng)建線程的名字
    public Executor ThreadPool1(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10); /** 核心線程數(shù)（默認(rèn)線程數(shù)） */
        executor.setMaxPoolSize(20);/** 最大線程數(shù) */
        executor.setQueueCapacity(500);/** 緩沖隊(duì)列大小 */
        executor.setKeepAliveSeconds(60);/** 允許線程空閑時(shí)間（單位：默認(rèn)為秒） */
        executor.setWaitForTasksToCompleteOnShutdown(true); 
        executor.setThreadNamePrefix("task-thread-"); /** 線程池名前綴 */
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy()); //拒絕策略：緩存隊(duì)列滿了之后由調(diào)用線程處理，一般是主線程
        executor.initialize();
        return executor;
    }
}

@RestController("/test")
public class Test2Controller {
    @Async("threadPool1")
    public void test1() throws InterruptedException {
        Thread.sleep(5000);
        System.out.println("test1");
    }
}

@Api("測(cè)試")
@RestController
@RequestMapping("/test/user")
public class TestController extends BaseController
{
    @Autowired
    private Test2Controller test2Controller;
    @ApiOperation("異步")
    @GetMapping("/testAsync")
    public String testAsync() throws InterruptedException {
        test2Controller.test1();
        return "async";
    }
}