@Configuration
@EnableAsync
public?class?ExecutorConfig?{

????private?static?final?Logger?logger?=?LoggerFactory.getLogger(ExecutorConfig.class);
????@Value("${async.executor.thread.core_pool_size}")
????private?int?corePoolSize;
????@Value("${async.executor.thread.max_pool_size}")
????private?int?maxPoolSize;
????@Value("${async.executor.thread.queue_capacity}")
????private?int?queueCapacity;
????@Value("${async.executor.thread.name.prefix}")
????private?String?namePrefix;
????@Bean(name?=?"asyncServiceExecutor")
????public?Executor?asyncServiceExecutor()?{
????????logger.info("start?asyncServiceExecutor");
????????ThreadPoolTaskExecutor?executor?=?new?ThreadPoolTaskExecutor();
????????//配置核心線程數(shù)
????????executor.setCorePoolSize(corePoolSize);
????????//配置最大線程數(shù)
????????executor.setMaxPoolSize(maxPoolSize);
????????//配置隊列大小
????????executor.setQueueCapacity(queueCapacity);
????????//配置線程池中的線程的名稱前綴
????????executor.setThreadNamePrefix(namePrefix);
????????// rejection-policy：當pool已經(jīng)達到max size的時候，如何處理新任務(wù)
????????// CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是有調(diào)用者所在的線程來執(zhí)行
????????executor.setRejectedExecutionHandler(new?ThreadPoolExecutor.CallerRunsPolicy());
????????//執(zhí)行初始化
????????executor.initialize();
????????return?executor;
????}
}

>?推薦下自己做的 Spring Cloud 的實戰(zhàn)項目：
>
>?<https://github.com/YunaiV/onemall>
#?異步線程配置
#?配置核心線程數(shù)
async.executor.thread.core_pool_size?=?5
#?配置最大線程數(shù)
async.executor.thread.max_pool_size?=?5
#?配置隊列大小
async.executor.thread.queue_capacity?=?99999
#?配置線程池中的線程的名稱前綴
async.executor.thread.name.prefix?=?async-service-

public?interface?AsyncService?{
????/**?*?執(zhí)行異步任務(wù)?*?可以根據(jù)需求，自己加參數(shù)擬定，我這里就做個測試演示?*/
????void?executeAsync();
}

@Service
public?class?AsyncServiceImpl?implements?AsyncService?{
????private?static?final?Logger?logger?=?LoggerFactory.getLogger(AsyncServiceImpl.class);
????@Override
????@Async("asyncServiceExecutor")
????public?void?executeAsync()?{
????????logger.info("start?executeAsync");
????????System.out.println("異步線程要做的事情");
????????System.out.println("可以在這里執(zhí)行批量插入等耗時的事情");
????????logger.info("end?executeAsync");
????}
}

@Autowired
private?AsyncService?asyncService;
@GetMapping("/async")
public?void?async(){
????asyncService.executeAsync();
}

import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import?org.springframework.util.concurrent.ListenableFuture;
import?java.util.concurrent.Callable;
import?java.util.concurrent.Future;
import?java.util.concurrent.ThreadPoolExecutor;
/**?*?@Author:?ChenBin?*?@Date:?2018/7/16/0016?22:19?*/
public?class?VisiableThreadPoolTaskExecutor?extends?ThreadPoolTaskExecutor?{

????private?static?final?Logger?logger?=?LoggerFactory.getLogger(VisiableThreadPoolTaskExecutor.class);
????private?void?showThreadPoolInfo(String?prefix)?{
????????ThreadPoolExecutor?threadPoolExecutor?=?getThreadPoolExecutor();
????????if?(null?==?threadPoolExecutor)?{
????????????return;
????????}
????????logger.info("{},?{},taskCount?[{}],?completedTaskCount?[{}],?activeCount?[{}],?queueSize?[{}]",
????????????????this.getThreadNamePrefix(),
????????????????prefix,
????????????????threadPoolExecutor.getTaskCount(),
????????????????threadPoolExecutor.getCompletedTaskCount(),
????????????????threadPoolExecutor.getActiveCount(),
????????????????threadPoolExecutor.getQueue().size());
????}
????@Override
????public?void?execute(Runnable?task)?{
????????showThreadPoolInfo("1.?do?execute");
????????super.execute(task);
????}
????@Override
????public?void?execute(Runnable?task,?long?startTimeout)?{
????????showThreadPoolInfo("2.?do?execute");
????????super.execute(task,?startTimeout);
????}
????@Override
????public?Future<?>?submit(Runnable?task)?{
????????showThreadPoolInfo("1.?do?submit");
????????return?super.submit(task);
????}
????@Override
????public?<T>?Future<T>?submit(Callable<T>?task)?{
????????showThreadPoolInfo("2.?do?submit");
????????return?super.submit(task);
????}
????@Override
????public?ListenableFuture<?>?submitListenable(Runnable?task)?{
????????showThreadPoolInfo("1.?do?submitListenable");
????????return?super.submitListenable(task);
????}
????@Override
????public?<T>?ListenableFuture<T>?submitListenable(Callable<T>?task)?{
????????showThreadPoolInfo("2.?do?submitListenable");
????????return?super.submitListenable(task);
????}
}

@Bean(name?=?"asyncServiceExecutor")
????public?Executor?asyncServiceExecutor()?{
????????logger.info("start?asyncServiceExecutor");
????????//在這里修改
????????ThreadPoolTaskExecutor?executor?=?new?VisiableThreadPoolTaskExecutor();
????????//配置核心線程數(shù)
????????executor.setCorePoolSize(corePoolSize);
????????//配置最大線程數(shù)
????????executor.setMaxPoolSize(maxPoolSize);
????????//配置隊列大小
????????executor.setQueueCapacity(queueCapacity);
????????//配置線程池中的線程的名稱前綴
????????executor.setThreadNamePrefix(namePrefix);
????????// rejection-policy：當pool已經(jīng)達到max size的時候，如何處理新任務(wù)
????????// CALLER_RUNS：不在新線程中執(zhí)行任務(wù)，而是有調(diào)用者所在的線程來執(zhí)行
????????executor.setRejectedExecutionHandler(new?ThreadPoolExecutor.CallerRunsPolicy());
????????//執(zhí)行初始化
????????executor.initialize();
????????return?executor;
????}