做酒的网站有哪些,网络规划设计师是副高,建设类招标代理公司网站,中囯军事网文章目录 前言一、创建线程池二、Future 类并发实现三、CompletableFuture 类并发实现 前言
当我们需要批量执行一些比较耗时任务时#xff0c;使用并发的方式减少业务处理的整体时间#xff0c;防止客户端响应时间过长。 一、创建线程池
import org.springframework.beans… 文章目录 前言一、创建线程池二、Future 类并发实现三、CompletableFuture 类并发实现 前言
当我们需要批量执行一些比较耗时任务时使用并发的方式减少业务处理的整体时间防止客户端响应时间过长。 一、创建线程池
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import lombok.extern.slf4j.Slf4j;import java.util.concurrent.ThreadPoolExecutor;/*** ClassName : ThreadPoolConfig* Description : ThreadPoolConfig* Author : zhuguangkui* Date: 2022-08-03*/
Configuration
Slf4j
public class ThreadPoolConfig {AutowiredThreadPoolProperties threadPoolProperties;/*** 获得Java虚拟机可用的处理器个数 1*/private static final int THREADS Runtime.getRuntime().availableProcessors() 1;/*** 默认情况下在创建了线程池后线程池中的线程数为0当有任务来之后就会创建一个线程去执行任务* 当线程池中的线程数目达到corePoolSize后就会把到达的任务放到缓存队列当中* 当队列满了就继续创建线程当线程数量大于等于maxPoolSize后开始使用拒绝策略拒绝*/Bean(name varHandleThreadPool)public ThreadPoolTaskExecutor varHandleThreadPool(){int corePoolSizeConfig threadPoolProperties.getCorePoolSizeConfig();//核心线程数int corePoolSize corePoolSizeConfig 0 ? THREADS : corePoolSizeConfig;ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setMaxPoolSize(2 * corePoolSize);executor.setCorePoolSize(corePoolSize);executor.setQueueCapacity(threadPoolProperties.getQueueCapacity());executor.setKeepAliveSeconds(threadPoolProperties.getKeepAliveSeconds());executor.setThreadNamePrefix(threadPoolProperties.getThreadNamePrefix());// 线程池对拒绝任务(无线程可用)的处理策略// CallerRunsPolicy由调用线程提交任务的线程处理该任务executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());// 初始化executor.initialize();log.info(doc 线程池初始化配置{}THREADS{}, threadPoolProperties, THREADS);return executor;}
}二、Future 类并发实现
/*** 批量并发处理业务*/
Override
public void generateBatchFile(ListString fileNameList) {ListFutureIdocDoc futureList new ArrayList(); // 并发处理结果集// 批量处理业务for (String fileName : fileNameList) {FutureIdocDoc future generateFile(fileName);futureList.add(future);}// 依次获取异步结果while (true) {for (FutureIdocDoc future : futureList) {if (future.isDone() !future.isCancelled()) { // 判断任务执行是否完成IdocDoc idocDoc future.get(); // 获取异步结果idocDocList.add(idocDoc);futureList.remove(future);}}if (CollectionUtil.isEmpty()) {break;}Thread.sleep(1); // 每次轮询休息1毫秒避免CPU占用}
}/*** 子业务*/
Async(varHandleThreadPool)
public FutureIdocDoc generateFile(String fileName) {IdocDoc idoDoc new IdoDoc();idocDoc.setName(fileName);... // 业务操作// 返回异步结果return new AsyncResult(idocDoc);
}三、CompletableFuture 类并发实现
/*** 批量并发处理业务*/
Override
public void generateBatchFile(ListString fileNameList) {ListCompletableFutureIdocDoc futureList new ArrayList(); // 并发处理结果集// 批量处理业务for (String fileName : fileNameList) {CompletableFutureIdocDoc future CompletableFuture.supplyAsync(() - {return generateFile(fileName);}, threadPoolTaskExecutor);futureList.add(future);}// 依次获取异步结果while (true) {for (CompletableFutureIdocDoc future : futureList) {if (future.isDone() !future.isCancelled()) { // 判断任务执行是否完成IdocDoc idocDoc future.get(); // 获取异步结果idocDocList.add(idocDoc);futureList.remove(future);}}if (CollectionUtil.isEmpty()) {break;}Thread.sleep(1); // 每次轮询休息1毫秒避免CPU占用}
}/*** 子业务*/
public IdocDoc generateFile(String fileName) {IdocDoc idoDoc new IdoDoc();idocDoc.setName(fileName);... // 业务操作// 返回异步结果return idocDoc;
}
