深圳网站建设服务哪家有,中国纪检监察报网站,朝阳市营商环境建设监督局网站,app开发做网站SpringBoot异步任务#xff08;2#xff09;|#xff08;线程池使用#xff09; 文章目录 SpringBoot异步任务#xff08;2#xff09;|#xff08;线程池使用#xff09;[TOC] 前言一、使用场景二、springboot添加异步任务1.配置线程池2.线程池的使用 总结 章节 第一章…SpringBoot异步任务2|线程池使用 文章目录 SpringBoot异步任务2|线程池使用[TOC] 前言一、使用场景二、springboot添加异步任务1.配置线程池2.线程池的使用 总结
章节 第一章链接: SpringBoot异步任务1|异步任务执行以及回调
前言
线程池开启异步任务在springboot中的使用
一、使用场景
项目中有一个批量调度的任务客户上传批量的文章让后将这些文章去进行任务处理
二、springboot添加异步任务
1.配置线程池 在springboot容器中配置线程池后续使用直接将bean注入使用即可 Configuration
EnableAsync
public class ExecutorEmbPoolConfig {private static final Logger logger LoggerFactory.getLogger(ExecutorEmbPoolConfig.class);Value(${embedding.pool.corePoolSize:20})private int corePoolSize 20;Value(${embedding.pool.maxPoolSize:20})private int maxPoolSize 20;Value(${embedding.pool.queueCapacity:100000})private int queueCapacity 100000;private String namePrefix embedding-service-;Bean(name embeddingServiceExecutor)public ThreadPoolTaskExecutor asyncServiceExecutor() {logger.debug(start embedding embeddingServiceExecutor);ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();//配置核心线程数executor.setCorePoolSize(corePoolSize);//配置最大线程数executor.setMaxPoolSize(maxPoolSize);//配置队列大小executor.setQueueCapacity(queueCapacity);//配置线程池中的线程的名称前缀executor.setThreadNamePrefix(namePrefix);// 允许回收核心线程executor.setAllowCoreThreadTimeOut(true);// CALLER_RUNS: 不在新线程中执行任务而是有调用者所在的线程来执行executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//执行初始化executor.initialize();return executor;}
}2.线程池的使用
Resource(name embeddingServiceExecutor)private ThreadPoolTaskExecutor executor;Scheduled(cron 0/30 * * * * ?)public void FileToMilvesJob() {//定义计数器ListDocumentMilvusRecord documentMilvusRecords recordService.findByStatus(RecordStatus.WAIT);if (CollectionUtils.isEmpty(documentMilvusRecords)) {return;}ListDocumentMilvusRecord excuteList;if (documentMilvusRecords.size() 50) {excuteList documentMilvusRecords.subList(0, 50);} else {excuteList documentMilvusRecords;}log.info(本次任务需要执行任务“{}条, excuteList.size());for (DocumentMilvusRecord record : excuteList) {recordService.updateRecordStatus(record);executor.execute(() - {try {docEmbeddingCreate(record); // 执行业务逻辑} catch (Exception e) {log.error(e.getMessage());}});}}
总结
上面的方式实现了自定义一个线程池然后执行任务的时候获取线程池并执行任务。
