位置：首页-资讯-后端开发

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

2023-05-30 19:01

短信预约 -IT技能 免费直播动态提醒

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

代码运行流程：

查出1300企业信息

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

导出(用jxl jar)

解决方案：

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

直接上代码

调用线程的代码

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);

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

java 多线程处理业务

阅读原文内容投诉