@Autowired private ExecutorService executorService;線程
Set<Callable<Map>> callables = new HashSet<Callable<Map>>();
callables.add(new Callable<Map>() {
public Map call() throws Exception {
Map map = new HashMap();
return map;
}
});
callables.add(new Callable<Map>() {
public Map call() throws Exception {
Map map = new HashMap();
return map;
}
});
callables.add(new Callable<Map>() {
public Map call() throws Exception {
Map map = new HashMap();
return map;
}
});
callables.add(new Callable<Map>() {
public Map call() throws Exception {
Map map = new HashMap();
return map;
}
});
callables.add(new Callable<Map>() {
public Map call() throws Exception {
Map map = new HashMap();
return map;
}
});
List<Future<Map>> futures = executorService.invokeAll(callables);// 收集線程返回的值get
for(Future<Map> future : futures) {
Map map = future.get();// 各個線程返回的map集合io
}List