import?java.util.concurrent.Executor;
import?java.util.concurrent.ThreadPoolExecutor;
import?org.springframework.context.annotation.Bean;
import?org.springframework.context.annotation.Configuration;
import?org.springframework.scheduling.annotation.EnableAsync;
import?org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

//啟動異步
@EnableAsync
//這是一個配置類
@Configuration
class?TaskPoolConfig?{
????//設(shè)置Bean的名稱不設(shè)置的話沒有辦法在?任務(wù)中對應(yīng)?配置信息
????@Bean("taskExecutor")
????public?Executor?taskExecutor()?{
????????//根據(jù)ThreadPoolTaskExecutor?創(chuàng)建建線程池
????????ThreadPoolTaskExecutor?executor?=?new?ThreadPoolTaskExecutor();
????????//為線程設(shè)置初始的線程數(shù)量?5條線程
????????executor.setCorePoolSize(5);
????????//為線程設(shè)置最大的線程數(shù)量?10條線程
????????executor.setMaxPoolSize(10);
????????//為任務(wù)隊(duì)列設(shè)置最大?任務(wù)數(shù)量
????????executor.setQueueCapacity(200);
????????//設(shè)置?超出初始化線程的?存在時間為60秒
????????//也就是?如果現(xiàn)有線程數(shù)超過5?則會對超出的空閑線程?設(shè)置摧毀時間?也就是60秒
????????executor.setKeepAliveSeconds(60);
????????//設(shè)置?線程前綴
????????executor.setThreadNamePrefix("taskExecutor-");
????????//線程池的飽和策略?我這里設(shè)置的是?CallerRunsPolicy?也就是由用調(diào)用者所在的線程來執(zhí)行任務(wù)?共有四種
????????//AbortPolicy：直接拋出異常，這是默認(rèn)策略；
????????//CallerRunsPolicy：用調(diào)用者所在的線程來執(zhí)行任務(wù)；
????????//DiscardOldestPolicy：丟棄阻塞隊(duì)列中靠最前的任務(wù)，并執(zhí)行當(dāng)前任務(wù)；
????????//DiscardPolicy：直接丟棄任務(wù)；
????????executor.setRejectedExecutionHandler(new?ThreadPoolExecutor.CallerRunsPolicy());
????????//設(shè)置在關(guān)閉線程池時是否等待任務(wù)完成
????????executor.setWaitForTasksToCompleteOnShutdown(true);
????????//設(shè)置等待終止的秒數(shù)
????????executor.setAwaitTerminationSeconds(60);
????????//返回設(shè)置完成的線程池
????????return?executor;
????}
}

import?lombok.extern.slf4j.Slf4j;
import?org.springframework.scheduling.annotation.Async;
import?org.springframework.stereotype.Component;
//啟用log?在控制臺輸出信息
@Slf4j
//啟用@Component?注解將該類注入到spring容器中
@Component
public?class?test?{
????//為Hello類方法設(shè)置異步調(diào)用的配置類
????@Async("taskExecutor")
????public?void?Hello(String?hello)?throws?InterruptedException?{
????????//開始執(zhí)行任務(wù)
????????log.info("任務(wù)開始并延長執(zhí)行時間");
????????//延遲執(zhí)行
????????Thread.sleep(1000);
???????//執(zhí)行輸出
????????log.info(hello);
????}
}

import?org.junit.Test;
import?org.junit.runner.RunWith;
import?org.springframework.beans.factory.annotation.Autowired;
import?org.springframework.boot.test.context.SpringBootTest;
import?org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public?class?ApplicationTests?{
????//自動裝配?線程測試類
????@Autowired
????private?test?test;
????
????@Test
????public?void?test()?throws?Exception?{
????????//循環(huán)跑30個任務(wù)
????????for?(int?i?=?0;i<30;i++){
????????????test.Hello("test"+i);
????????}
????}
}