java多次嵌套循环查询数据库导致代码中数据处理慢的解决
更新时间:2023年03月15日 09:22:44 作者:念旧、sunshine
这篇文章主要介绍了java多次嵌套循环查询数据库导致代码中数据处理慢的解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
业务现象
代码中有一部分代码多次嵌套循环和数据处理,执行速度很慢
解决方案
通过多线程
1、启用多线程
private final static Executor executor = Executors.newFixedThreadPool(3);
2、初始化设置count
即等待(await)count个线程或一个线程count次计数,通过工作线程来countDown计数减一,直到计数为0,await阻塞结束;目的:保证所有线程都走完
final CountDownLatch latch = new CountDownLatch(dataList.size());
3、需要重新run
需要多线程的代码写在run中
@Override public void run() { //业务代码处理 //countDown计数减一 latch.countDown(); }
4、阻塞线程
// 等待所有工作线程结束 latch.await();
关键代码
private final static Executor executor = Executors.newFixedThreadPool(3);//启用多线程 public Result getList(@RequestBody StatusDbSelectParam param){ PageHelper.startPage(param.getPageNum(), param.getPageSize()); List<Map<String, Object>> dataList = statusDbService.selectByTime(tableName, columnNames.toString(), param.getStartTime(), param.getEndTime()); //初始化设置count,即等待(await)count个线程或一个线程count次计数,通过工作线程来countDown计数减一,直到计数为0,await阻塞结束 final CountDownLatch latch = new CountDownLatch(dataList.size()); for(int k =0;k<dataList.size();k++) { final int i = k; String finalTableName = tableName; executor.execute(new Runnable() { @Override public void run() { try { Map<String, Object> map = dataList.get(i); for (String pid : map.keySet()) { String val = String.valueOf(map.get(pid)); String columPid = pid.substring(2, pid.length()).toLowerCase(); List<MonitorRuleEntity> list = monitorRuleService.listMonitorRule(columPid, finalTableName); String status = ""; //循环规则数据 判断监测点是否报警 更新状态 for (int j = 0; j < list.size(); j++) { Boolean flag = DevHealthStatusFactory.getInstance().getResultMapByRule(val, list.get(j)); if (flag) { if (j == 0) { status = "A"; break; } else if (j == 1) { status = "B"; break; } else if (j == 2) { status = "C"; break; } } } if (pid.equalsIgnoreCase(timeColumnName)) { map.put(pid, val); } else { map.put(pid, val + "_" + status); } } latch.countDown(); } catch (Exception e) { e.printStackTrace(); } } }); } try { // 等待所有工作线程结束 latch.await(); } catch (InterruptedException e) { e.printStackTrace(); } return ResultMsg.successMsg().data(new PageInfo<>(dataList)); }
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
SpringDataJpa的使用之一对一、一对多、多对多 关系映射问题
这篇文章主要介绍了SpringDataJpa的使用 -- 一对一、一对多、多对多关系映射,本文主要讲述 @OneToOne、@OneToMany、@ManyToOne、@ManyToMany 这四个关系映射注解的使用,以及其对应的级联关系,需要的朋友可以参考下2022-07-07SpringCloud eureka(server)微服务集群搭建过程
这篇文章主要介绍了微服务SpringCloud-eureka(server)集群搭建, 项目搭建的主要步骤和配置就是创建项目和引入pom依赖,本文通过图文示例代码相结合给大家介绍的非常详细,需要的朋友可以参考下2022-07-07jmeter添加自定函数的实例(jmeter5.3+IntelliJ IDEA)
这篇文章主要介绍了jmeter添加自定函数的实例(jmeter5.3+IntelliJ IDEA),本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下2020-11-11Spring中的@ExceptionHandler注解统一异常处理详解
这篇文章主要介绍了Spring中的@ExceptionHandler注解统一异常处理详解,当我们使用这个@ExceptionHandler注解时,定义一个异常的处理方法,加上@ExceptionHandler注解,这个方法就会处理类中其他方法抛出的异常,需要的朋友可以参考下2024-01-01
最新评论