Java多线程执行处理业务时间太久解决方法代码示例

 更新时间:2017年12月06日 14:23:18   作者:sunlei198906  
这篇文章主要介绍了Java多线程执行处理业务时间太久解决方法代码示例的相关资料,具有一定借鉴价值,需要的朋友可以参考下。

背景:在政府开发了一个应用系统,主要功能是让企业填写企业资质信息,然后通过给定的公式,统计这一系列的信息,以得分的形式展示给政府领导查看。目前有1300家企业填报。由于得分是实时显示的,所以导致统计功能很慢。

代码运行流程

1、查出1300企业信息

2、遍历1300企业信息,ji计算每家企业得分信息。每家预计时间为0.3秒。合计390秒。导致页面请求超时

3、导出(用jxl jar)

解决方案:

由于处理业务的,所以需要能有返回值的线程。用:Callable

直接上代码

1、调用线程的代码

List<Map<String,Object>> list = (List<Map<String, Object>>) map.get("rows");
int taskSize = 20;
// 创建一个线程池
ExecutorService pool = Executors.newFixedThreadPool(taskSize);
// 创建多个有返回值的任务 
List<Future> listFuture = new ArrayList<Future>();
for (int i = 0; i < taskSize; i++) {
	System.out.println("我启用多线程啦啦啦");
	int evgCount = list.size()/taskSize;
	Callable c = new MyCallable(list.subList(evgCount*i, evgCount*(i+1)),session,staticFlag,
	declareService,declareMasterService,enterpriseQueryService);
	// 执行任务并获取Future对象
	Future f = pool.submit(c);
	listFuture.add(f);
}
pool.shutdown();
// 获取所有并发任务的运行结果 
List<Map<String, Object>> listResult = new ArrayList<Map<String, Object>>();
for (Future f : listFuture) {
	List<Map<String, Object>> listModel = new ArrayList<Map<String, Object>>();
	try {
		listModel = (List<Map<String, Object>>) f.get();
	}
	catch (InterruptedException e) {
		e.printStackTrace();
	}
	catch (ExecutionException e) {
		e.printStackTrace();
	}
	listResult.addAll(listModel);
}
map.put("rows", listResult);

2、线程的代码

package usi.jszx.controller;
import java.util.List;
import java.util.Map;
import java.util.concurrent.Callable;
import javax.servlet.http.HttpSession;
import org.apache.commons.lang3.StringUtils;
import usi.jszx.entity.ScoreMain;
import usi.jszx.service.DeclareMasterService;
import usi.jszx.service.DeclareService;
import usi.jszx.service.EnterpriseQueryService;
import usi.sys.dto.AuthInfo;
import usi.sys.util.ConstantUtil;
class MyCallable implements Callable<Object> {
	//-----------------以下为线程调用的方法----------------
	private List<Map<String,Object>> list;
	private HttpSession session;
	private String staticFlag;
	private DeclareService declareService;
	private DeclareMasterService declareMasterService;
	private EnterpriseQueryService enterpriseQueryService;
	public MyCallable(List<Map<String,Object>> list,HttpSession session,String staticFlag,
	DeclareService declareService,DeclareMasterService declareMasterService,EnterpriseQueryService enterpriseQueryService) {
		this.list = list;
		this.session = session;
		this.staticFlag = staticFlag;
		this.declareService = declareService;
		this.declareMasterService = declareMasterService;
		this.enterpriseQueryService = enterpriseQueryService;
	}
	@Override
	public Object call() throws Exception {
		AuthInfo info = (AuthInfo)session.getAttribute(ConstantUtil.AUTH_INFO);
		for (int i = 0; i < list.size(); i++) {
			Map<String,Object> maplist = list.get(i);
			String mainId= maplist.get("ID")+"";
			this.gradeMaster(session, mainId, maplist.get("orgId")+"",declareMasterService,enterpriseQueryService);
			List<Map<String,Object>> listscore = declareMasterService.queryScoreMain(maplist.get("ID")+"",info.getRightType(), "report");
			// declareMasterService.queryScoreMain(mainId,info.getRightType(),isreport);
			int isdouble = 1;
			if(listscore.size()>30){
				maplist.put("SOCRETOTAL", listscore.get(46).get("SCORE"));
				isdouble = 2;
			} else if(listscore.size()>22){
				maplist.put("SOCRETOTAL", listscore.get(23).get("SCORE"));
			}
			if("3".equals(staticFlag)){
				for (int j = 0; j < 23; j++) {
					if(j<9){
						maplist.put("VALUE0"+(j+1), listscore.get(j*isdouble).get("SHOW_VALUE"));
					} else{
						maplist.put("VALUE"+(j+1), listscore.get(j*isdouble).get("SHOW_VALUE"));
					}
				}
			}
			//地市展示
			String COUNTYID = maplist.get("COUNTYID")+"";
			if("340826".equals(COUNTYID)||"341822".equals(COUNTYID)){
				maplist.put("CITYNAME",maplist.get("COUNTYNAME")+"");
			}
			//企业类型
			String DECLARE_EVALUATE = maplist.get("DECLARE_EVALUATE")+"";
			if("1".equals(DECLARE_EVALUATE)){
				maplist.put("DECLARE_EVALUATE_NAME","申报");
			} else{
				maplist.put("DECLARE_EVALUATE_NAME","评价");
			}
			//审核状态
			String SHSTATUS = maplist.get("SHSTATUS")+"";
			if("9".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "草稿");
			} else if("0".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "企业提交");
			} else if("1".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "市审核通过");
			} else if("2".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "市审核不通过");
			} else if("3".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "省审核通过");
			} else if("4".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "省审核不通过");
			} else if("5".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "省级审核中");
			} else if("6".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "退回企业修改");
			} else if("7".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "市级审核中");
			} else if("11".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "修改为申报");
			} else if("12".equals(SHSTATUS)){
				maplist.put("STRSHSTATUS", "修改为评价");
			}
			if("1".equals(staticFlag)){
				//添加修改意见
				List<Map<String, Object>> listDetail = declareService.queryAuditLog(mainId);
				if(listDetail.size()>0){
					String AUDIT_OPINION = listDetail.get(0).get("AUDIT_OPINION")+"";
					if(!StringUtils.isEmpty(AUDIT_OPINION)&&!"null".equals(AUDIT_OPINION)){
						maplist.put("AUDIT_OPINION", AUDIT_OPINION);
					} else{
						maplist.put("AUDIT_OPINION", "");
					}
				}
				//是否更名 曾用名
				String ORGNAME = maplist.get("ORGNAME")+"";
				String PJNAME = maplist.get("PJNAME")+"";
				if(StringUtils.isEmpty(PJNAME)||"null".equals(PJNAME)
				||PJNAME.equals(ORGNAME)){
					maplist.put("ISGENGMING", "否");
					maplist.put("PJNAME_E", "");
				} else{
					maplist.put("ISGENGMING", "是");
					maplist.put("PJNAME_E", PJNAME);
				}
			} else if("2".equals(staticFlag)){
			}
		}
		return list;
	}
	public float gradeMaster(HttpSession session,String mainId,String orgId,
	DeclareMasterService declareMasterService,EnterpriseQueryService enterpriseQueryService) {
		AuthInfo info = (AuthInfo)session.getAttribute(ConstantUtil.AUTH_INFO);
		String rightType=info.getRightType();
		declareMasterService.deleteScoreMain(mainId);
		float[] resultFirst = new float[100];
		/*
* 先查询所有 附表列表
* 查看得分的地方,是直接查找主表数据的
* 
* 既然审核了,主表数据肯定存起来了
* */
		List<Map<String,Object>> listDetail = declareMasterService.queryTaskDetail(mainId);
		if("2".equals(rightType)||"3".equals(rightType)){
			//将String 转为 float
			for (int i = 0; i < listDetail.size(); i++) {
				Map<String,Object> map = listDetail.get(i);
				if(StringUtils.isEmpty(map.get("DECLARE_CITY_VALUE")+"")
				||"null".equals(map.get("DECLARE_CITY_VALUE")+"")){
					resultFirst[i]=0f;
				} else{
					resultFirst[i] = float.parsefloat(map.get("DECLARE_CITY_VALUE")+"");
				}
			}
		} else{
			//将String 转为 float
			for (int i = 0; i < listDetail.size(); i++) {
				Map<String,Object> map = listDetail.get(i);
				if(StringUtils.isEmpty(map.get("DECLARE_PROVINCE_VALUE")+"")
				||"null".equals(map.get("DECLARE_PROVINCE_VALUE")+"")){
					resultFirst[i]=0f;
				} else{
					resultFirst[i] = float.parsefloat(map.get("DECLARE_PROVINCE_VALUE")+"");
				}
			}
		}
		Map<String,Object> enterprise= enterpriseQueryService.getInfoByOrgId(orgId).get(0);
		//根据 安徽省企业技术中心评价指标计算公式 进行算值 下一步算分
		float ratio1 = 0f;
		float ratio2 = 0f;
		float ratio3 = 0f;
		try {
			ratio1 = float.parsefloat(enterprise.get("RATIO1")+"");
			ratio2 = float.parsefloat(enterprise.get("RATIO2")+"");
			ratio3 = float.parsefloat(enterprise.get("RATIO3")+"");
		}
		catch (Exception e) {
		}
		Map<String,Object> map = DeclareController.getValue(resultFirst,ratio1,ratio2,ratio3);
		float[] resultValue = (float[]) map.get("resultValue");
		float[] resultScoreValue = (float[]) map.get("resultScoreValue");
		float[] resultScore = DeclareController.getScore(resultScoreValue);
		float scoreTotal = 0f;
		List<Map<String,Object>> listScore = declareMasterService.queryScoreDic();
		for (int i = 0; i < listScore.size(); i++) {
			ScoreMain scoreMain = new ScoreMain();
			scoreMain.setMainId(mainId);
			scoreMain.setScoreName(listScore.get(i).get("SCORE_NAME")+"");
			scoreMain.setScoreUnit(listScore.get(i).get("SCORE_UNIT")+"");
			scoreMain.setScoreWeight(listScore.get(i).get("SCORE_WEIGHT")+"");
			scoreMain.setDisOrder(listScore.get(i).get("DIS_ORDER")+"");
			scoreMain.setShowValue(resultValue[i]+"");
			scoreMain.setScoreValue(resultScoreValue[i]+"");
			scoreMain.setScore(resultScore[i]+"");
			declareMasterService.inserScoreMain(scoreMain);
			scoreTotal +=resultScore[i];
		}
		return scoreTotal;
	}
}

说明:MyCallable仅仅是业务处理方式繁杂。可忽略,最后从390秒提速致40秒。

总结

以上就是本文关于Java多线程执行处理业务时间太久解决方法代码示例的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!

相关文章

  • java对象list使用stream根据某一个属性转换成map的3种方式举例

    java对象list使用stream根据某一个属性转换成map的3种方式举例

    开发小伙伴们通常会需要使用到对象和Map互相转换的开发场景,下面这篇文章主要给大家介绍了关于java对象list使用stream根据某一个属性转换成map的3种方式,需要的朋友可以参考下
    2024-01-01
  • Java中的TreeMap底层源码分析

    Java中的TreeMap底层源码分析

    这篇文章主要介绍了Java中的TreeMap底层源码分析,TreeMap与Hashmap、LinkedHashMap不同,他的底层不再是数组,而是一颗红黑树,在插入、删除或者替换元素时,TreeMap能按照事先约定的顺序来对key进行排序和迭代查询,需要的朋友可以参考下
    2023-12-12
  • SpringMVC 向jsp页面传递数据库读取到的值方法

    SpringMVC 向jsp页面传递数据库读取到的值方法

    下面小编就为大家分享一篇SpringMVC 向jsp页面传递数据库读取到的值方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-03-03
  • SpringBoot项目防止反编译的方案

    SpringBoot项目防止反编译的方案

    最近项目要求部署到其他公司的服务器上,但是又不想将源码泄露出去,要求对正式环境的启动包进行安全性处理,防止客户直接通过反编译工具将代码反编译出来,所以本文给大家介绍了SpringBoot项目如何防止反编译,需要的朋友可以参考下
    2024-01-01
  • mybatis实现表与对象的关联关系_动力节点Java学院整理

    mybatis实现表与对象的关联关系_动力节点Java学院整理

    这篇文章主要介绍了mybatis实现表与对象的关联关系_动力节点Java学院整理,需要的朋友可以参考下
    2017-09-09
  • Mybatis MappedStatement类核心原理详解

    Mybatis MappedStatement类核心原理详解

    这篇文章主要介绍了Mybatis MappedStatement类,mybatis的mapper文件最终会被解析器,解析成MappedStatement,其中insert|update|delete|select每一个标签分别对应一个MappedStatement
    2022-11-11
  • Java 实战项目锤炼之嘟嘟健身房管理系统的实现流程

    Java 实战项目锤炼之嘟嘟健身房管理系统的实现流程

    读万卷书不如行万里路,只学书上的理论是远远不够的,只有在实战中才能获得能力的提升,本篇文章手把手带你用java+SSM+jsp+mysql+maven实现一个健身房管理系统,大家可以在过程中查缺补漏,提升水平
    2021-11-11
  • java中循环删除list中元素的方法总结

    java中循环删除list中元素的方法总结

    下面小编就为大家带来一篇java中循环删除list中元素的方法总结。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-12-12
  • Java 源码重读系列之 HashMap

    Java 源码重读系列之 HashMap

    这篇文章主要为大家介绍了Java源码重读系列之HashMap示例解析,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-04-04
  • java网上商城开发之邮件发送功能(全)

    java网上商城开发之邮件发送功能(全)

    这篇文章主要介绍了java网上商城开发之邮件发送功能,第一部分介绍了环境配置,第二部分则介绍了具体实现代码,感兴趣的小伙伴们可以参考一下
    2016-03-03

最新评论