Java利用多线程执行SQL减少执行时间提高效率

首先这是个人在实际的项目中使用的代码，部分敏感代码没有上，不过不影响对代码的理解：

1.实现自己的线程

/**

• @author
• TODO:收款率线程
• / public class Thread2CollectionRate implements Runnable{private String sql;private List<Map<String, Object>> listMap ;@Override public void run() { //此处线程中获取DAO实例是通过spring注入，各位可以根据自己的方式注入 BaseService service = (BaseService)SpringContextUtil.getService("service"); List<Map<String, Object>> list = service.getList(sql);System.out.println("run tread ok ..................................." + list.size()); //添加数据到MAP中去 if(listMap != null) { listMap.addAll(list); }

}

public String getSql() { return sql; }

public void setSql(String sql) { this.sql = sql; }

/**

• @return the listMap
• / public List<Map<String, Object>> getListMap() { return listMap; }

/**

• @param listMap the listMap to set
• / public void setListMap(List<Map<String, Object>> listMap) { this.listMap = listMap; }

}

2.循环调用线程

String sql = "你的SQL语句";

//定义线程池 ExecutorService e = Executors.newCachedThreadPool();

List<Map<String, Object>> listMap = new LinkedList<Map<String, Object>>();

for(int i = 0 ; i < 6; i++) { String tempSql = "需要分线程执行的SQL语句"; Thread2CollectionRate tempTread = new Thread2CollectionRate(); //把需要装数据的Map放到线程中去 tempTread.setListMap(listMap); //把需要执行的SQL放到线程中去 tempTread.setSql(tempSQL); //执行线程 e.execute(tempTread);

}

//通知关闭线程池 e.shutdown(); //死循环等待线程池完全关闭，只有所有的线程全部执行完毕e.isTerminated()等于true

try { while(true) { if(e.isTerminated()) { //listMap中就是你所需要的全部数据 System.out.println("listMap.size() :" + listMap.size()); break; } //每次循环等待250毫秒 Thread.sleep(250); } } catch (InterruptedException e1) { e1.printStackTrace(); }

}

原文地址：https://blog.csdn.net/foreversilent/article/details/78602991?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522168474995516800188548878%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fall.%2522%257D&request_id=168474995516800188548878&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~all~first_rank_ecpm_v1~rank_v31_ecpm-15-78602991-null-null.142^v87^control_2,239^v2^insert_chatgpt&utm_term=java%E4%BC%98%E5%8C%96