如何在循环中使用线程并行调用方法，避免等待执行完成？

当然可以并行调用method(value)来提升执行效率，下面是几种常用的实现方式：

1. 使用ExecutorService线程池 #

通过线程池批量提交异步任务，先全部提交再统一收集结果，避免逐个等待的低效问题：

// 根据系统CPU核心数初始化线程池，可按需调整线程数量
ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
List<Future<Object>> futures = new ArrayList<>();

while (iter.hasNext()) {
    Object value = iter.next();
    // 提交任务到线程池，立即返回Future对象，不阻塞当前线程
    futures.add(executor.submit(() -> method(value)));
}

// 统一等待所有任务完成并收集结果
for (Future<Object> future : futures) {
    try {
        result.add(future.get());
    } catch (InterruptedException | ExecutionException e) {
        // 根据业务需求处理异常，比如记录日志、返回默认值等
        e.printStackTrace();
    }
}

// 任务全部完成后关闭线程池
executor.shutdown();

2. 使用Java并行流（Java 8+） #

如果迭代器可以转换为Stream，用并行流能以极简的代码实现并行执行：

// 将迭代器转换为并行流，Spliterator.ORDERED保证结果顺序与原迭代一致
Stream<Object> parallelStream = StreamSupport.stream(
    Spliterators.spliteratorUnknownSize(iter, Spliterator.ORDERED), 
    true // 开启并行模式
);

// 并行执行method并收集结果
result = parallelStream.map(this::method).collect(Collectors.toList());

注意：并行流默认使用ForkJoinPool，若需自定义线程池，可通过ForkJoinPool的API指定执行池。

3. 使用CompletableFuture（Java 8+） #

提供更灵活的异步控制，支持任务编排、异常处理等高级特性：

List<CompletableFuture<Object>> futures = new ArrayList<>();

while (iter.hasNext()) {
    Object value = iter.next();
    // 异步执行任务，可传入自定义线程池替代默认池
    futures.add(CompletableFuture.supplyAsync(() -> method(value)));
}

// 等待所有任务完成
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();

// 提取所有任务的执行结果
for (CompletableFuture<Object> future : futures) {
    result.add(future.join());
}

关键注意事项 #

• 确保method(value)是线程安全的，避免多线程调用时出现竞态条件。
• 根据任务类型调整线程池大小：CPU密集型任务建议线程数等于CPU核心数；IO密集型任务可设置更大的线程数（如CPU核心数×2）。
• 完善异常处理逻辑，避免单个任务失败导致整个流程阻塞或结果丢失。

内容的提问来源于stack exchange，提问作者Manoj Kumar