java 线程池获取全部线程返回结果

@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

相关文章
相关标签/搜索