多并发下多线程遍历list问题

今天做导出 查出的数据有3万条 还要遍历做一些处理 结果就超时
想到多线程遍历list 去网上查找 找到这块代码:

public String list2Str(List<String> list, final int nThreads) throws Exception {  
            if (list == null || list.isEmpty()) {  
                return null;  
            }  
              
            StringBuffer ret = new StringBuffer();  
      
            int size = list.size();  
            ExecutorService executorService = Executors.newFixedThreadPool(nThreads);  
            List<Future<String>> futures = new ArrayList<Future<String>>(nThreads);  
              
            for (int i = 0; i < nThreads; i++) {  
                final List<String> subList = list.subList(size / nThreads * i, size / nThreads * (i + 1));  
                Callable<String> task = new Callable<String>() {  
                    @Override  
                    public String call() throws Exception {  
                        StringBuffer sb = new StringBuffer();  
                        for (String str : subList) {  
                            sb.append(str);  
                        }  
                        return sb.toString();  
                    }  
                };  
                futures.add(executorService.submit(task));  
            }  
              
            for (Future<String> future : futures) {  
                ret.append(future.get());  
            }  
            executorService.shutdown();  
              
            return ret.toString();  
        }  
    } 

我调用时开了5个线程 我想问 每次导出就开启5个线程 如果多个人同时导出 比如10000个人同时导出 那岂不是就开启了50000个线程了!!!

没问题吗???

阅读 5.1k
2 个回答

既然已经使用过线程池,就不存在线程被大量创建的问题。Java7出了一个Fork/Join框架,利用多线程并行计算,跟这个业务有点相似,楼主可以自行去了解下

没看代码,这个明显是串行任务,局部并行处理,简单点可以用线程池和countdownlatch来做
楼上说可以用Fork/Join框架,分而治之的思想,其实要是支持jdk8的话,也可以用并行流parallelstream来做,底层就是Fork/Join,要代码的话回头给你写一下

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进