本文介绍一种灵活、可扩展的 Java 方案，通过组合 ExecutorService 实现“部分任务串行执行 + 部分任务并行执行 + 最终结果聚合后继续串行”的工作流，适用于任务数量动态变化的业务场景。

本文介绍一种灵活、可扩展的 Java 方案，通过组合 `ExecutorService` 实现“部分任务串行执行 + 部分任务并行执行 + 最终结果聚合后继续串行”的工作流，适用于任务数量动态变化的业务场景。

在实际开发中，常遇到需协调异步执行逻辑的复合任务流：例如，先顺序执行一组依赖型操作（如数据准备 t1→t2→t3），同时并行执行一个耗时但无依赖的操作（如远程配置加载 t4），待全部完成后再统一处理结果并继续后续串行步骤（如组装响应 t5→t6）。Java 原生并发工具完全可优雅支撑该模式，关键在于合理分层调度与精准同步控制。

以下是一个生产就绪的通用实现，支持任意长度的串行任务列表和独立并行任务：

import java.util.List; import java.util.concurrent.*; import java.util.function.Supplier;

public class HybridTaskRunner

 return results; }, seqExecutor); // Step 2: 并行执行独立任务（t4） CompletableFuture 
  
    
    
      parallelFuture = CompletableFuture.supplyAsync(parallelTask, parallelExecutor); // Step 3: 等待两者完成，并合并结果 CompletableFuture 
     
       > mergedResults = seqFuture .thenCombine(parallelFuture, (seqRes, parRes) -> { List 
      
        all = new CopyOnWriteArrayList(seqRes); all.add(parRes); return all; }); // Step 4: 执行最终串行链（t5→t6），以合并结果为输入 return mergedResults .thenApply(results -> { R result = null; for (Function 
       
         , R> finalTask : finalSeqTasks) { result = finalTask.apply(results); } return result; }) .get(30, TimeUnit.SECONDS); // 带超时的阻塞获取 } finally if (!parallelExecutor.awaitTermination(5, TimeUnit.SECONDS)) { parallelExecutor.shutdownNow(); } } } 
        
       
      
    

}

List 
 
   
   
    
    
   > prepTasks = List.of( () -> { System.out.println("t1: load user"); return "user"; }, () -> { System.out.println("t2: validate token"); return "token"; }, () -> { System.out.println("t3: fetch profile"); return "profile"; } ); Supplier 
  
    
    
      backgroundTask = () -> { try { Thread.sleep(2000); } catch (InterruptedException e) { } System.out.println("t4: fetch analytics (async)"); return "analytics"; }; List 
     
       , String>> postTasks = List.of( results -> { System.out.println("t5: merge data: " + results); return "merged"; }, results -> { System.out.println("t6: generate response"); return "OK"; } ); try { String finalResult = HybridTaskRunner.runHybrid(prepTasks, backgroundTask, postTasks); System.out.println("✅ Final result: " + finalResult); } catch (Exception e) { e.printStackTrace(); } 
      
     
 
   
   

• 避免线程泄漏：务必在 finally 块中调用 shutdown() + awaitTermination()，或使用 try-with-resources 封装（需自定义 AutoCloseableExecutor）；
• 异常传播：CompletableFuture 默认不中断其他分支，建议使用 exceptionally() 或 handle() 显式捕获各阶段异常；
• 结果类型统一：若串行/并行任务返回不同类型，可封装为 Result 容器类，或改用 CompletableFuture
• 性能考量：对大量短任务，优先复用 ForkJoinPool.commonPool()；高吞吐场景建议配置有界队列的 ThreadPoolExecutor；
• 扩展性增强：可进一步抽象为 DSL 风格 API，如 .sequence(…).parallel(…).then(…) 链式调用。

该方案兼顾清晰性、健壮性与可维护性，无需第三方库，纯 JDK 11+ 即可运行，是构建复杂异步工作流的可靠基础。

Java免费学习笔记：立即使用

 
解锁 Java 大师之旅：从入门到精通的终极指南