项目中线程池的应用

悠悠 2022-11-29 13:19 181阅读 0赞

# 注意红色字体部分 #

业务需求：数据可能来自不同的数据源，mysql,oracle,或者远程接口（分为两个实现类:数据和api）

用线程池调用

**1**.service层核心代码：

@Autowired

//数据和api的实现类，继承AbstractDataHanderService，AbstractDataHanderService为抽象类，

private Map<String,AbstractDataHanderService> handerServiceMap;

**private ThreadPoolExecutor threadPool;**

**//下面初始化线程池**

**@PostConstruct**

**private void initThreadPool()\{**

** ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("engine-%d").setDaemon(true).build();**

**threadPool = new ThreadPoolExecutor(20,32,50L,TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(32),threadFactory);**

**threadPool.prestartAllCoreThreads();**

**\}**

@Override

public List<IndicatorDataRespDTO> getIndicatorData(IndicatorReqDTO reqDTO,userCode)\{

.....省略部分代码

List<IndicatorDataDTO> dataDtoList = new ArrayList<>();  // 返回的结果

**List<Future<List<IndicatorDataDTO>>> futures = new ArrayList<>();  //有返回结果的线程用future接收**

for()\{

//遍历调用数据或api的实现类，hanlerServiceMap.get()就是得到实现service,

//getHandlerList方法封装要执行的对象

**List<AbstractGetDataHandler> handerList** = hanlerServiceMap.get(entry.getKey()+"\_dataHandlerService")

.getHandlerList(reqDTO,entry.getValue(),getGroupReqFields());

**  futures.addAll(threadPool.invokeAll(handlerList));//这一步是真正的执行，执行的是上一步封装对象里的方法**

\}

//合并结果数据

for(Future<List<IndicatorDataDTO>> future:futures)\{

List<IndicatorDataDTO> resultDataList = future.get();

if(!CollectionUtils.isEmpty(resultDataList))\{

dataDtoList.addAll(resultDataList);

\}

\}

\}

**2.** 注意上一段代码封装的执行对象 List<AbstractGetDataHandler> handerList =

和List<Future<List<IndicatorDataDTO>>> futures = new ArrayList<>();  //有返回结果的线程用future接收

AbstractGetDataHandler 抽象类：**注意这里实现implements Callable<List<IndicatorDataDTO>>**

@Slf4j

@Data

public abstract class **AbstractGetDataHandler implements Callable<List<IndicatorDataDTO>>**\{

public abstract List<IndicatorDataDTO> getIndicatorData(); //处理业务在这个方法的实现里面，

//**注意这个方法的返回List<IndicatorDataDTO>和List<Future<List<IndicatorDataDTO>>> futures = new ArrayList<>();**

\}

**3**.实现类里getHandlerList方法核心代码

//返回List<AbstractGetDataHandler> dataHandlerList

//这里注意DataBaseGetDataHandler 继承了上面AbstractGetDataHandler ，并实现了getIndicatorData方法

//

dataHandlerList.add(**new DataBaseGetDataHandler**(jdbcTemplate,paramMap,dataPath,type,engineDbConfig));

4.**DataBaseGetDataHandler**

@Slf4j

@Data

@AllArgsConstructor

@NoArgsConstructor

public class **DataBaseGetDataHandler extends AbstractGetDataHander\{**

//实现   getIndicatorData ，在这里业务处理

@Override

public List<IndicatorDataDTO> getIndicatorData()\{

。。。。。。

\}

# //注意下面这个方法，重点！ #

# **@Override** #

# **public List<IndicatorDataDTO> call() thows Exception\{**  #

# **  return getIndicatorData** #

# **\}** #

# **\}** #

发表评论取消回复

表情：

评论列表（有 0 条评论，181人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java如何创建线程池?项目中如何使用线程池

介绍几种线程池的创建方式, 以及简单介绍在项目中如何使用线程池

我就是我/ 2024年05月05日 22:22/ 0 赞/ 74 阅读

相关线程池在项目中的实战

> 线程池的原理和作用相比大家都比较了解了，不熟悉的可以看这篇文章 > 链接: [线程池的使用(点击查看)][Link 1]. 一个项目中要求对丢MQ队列的消息用线程池接

柔光的暖阳◎/ 2023年10月10日 09:18/ 0 赞/ 6 阅读

相关【并发编程六：Java中的线程池（3）-线程池的应用】

【衔接上一章 [【并发编程五：Java中的线程池（2）-线程的实现原理】][Java_2_-]】学习路线 1.9工作中线程池的应用 1

╰半夏微凉°/ 2023年10月09日 14:09/ 0 赞/ 49 阅读

相关线程池的应用

创建多线程的方式： 1. 继承Thread类创建线程类，重写run()方法 1. 调用步骤，创建继承类的对象t,执行t.start() 2. 通过

左手的ㄟ右手/ 2023年09月28日 23:52/ 0 赞/ 23 阅读

相关线程应用（线程池）

线程池：创建一堆工作线程（有最大数量限制），以及一个线程安全的队列，这些工作线程不断从任务队列取出任务进行处理优点： 1. 避免资源无限制使用所造成的资源耗尽的

待我称王封你为后i/ 2023年01月16日 12:24/ 0 赞/ 153 阅读

相关项目中线程池的应用

注意红色字体部分业务需求：数据可能来自不同的数据源，mysql,oracle,或者远程接口（分为两个实现类:数据和api）用线程池调用 1.service层核心代

悠悠/ 2022年11月29日 13:19/ 0 赞/ 182 阅读

相关 Java多线程七:线程池应用

java线程池应用概述当有多个请求到服务器需要新建线程来执行任务时，如果为每个请求都新建线程的话，那么服务器资源开销比较大，因此使用一个容器来管理线程，当请

缺乏、安全感/ 2022年09月25日 06:29/ 0 赞/ 183 阅读

相关 Tornado 线程池应用

Tornado是一个异步框架，在异步操作的时候能提升程序的处理性能。但是如果在程序中碰到同步的逻辑，由于GIL的关系，会直接卡死，导致性能急剧下降。目前对于mongodb以

阳光穿透心脏的1/2处/ 2022年06月08日 00:21/ 0 赞/ 173 阅读

相关线程池的实际应用场景

在实际应用中使用java中的线程池，我构建了一个线程数为5个线程池，然后采用分段批量提取的方式每500条为一组数据进行图片信息的提取，然后再把这些通过Threadpool的ex

喜欢ヅ旅行/ 2022年01月23日 23:19/ 0 赞/ 282 阅读

相关 Java线程池的应用

一使用Future与Callable来计算斐波那契数列 1 代码 import java.util.concurrent.; public class F

Love The Way You Lie/ 2021年09月29日 14:16/ 0 赞/ 281 阅读