Java多任务依赖处理：CompletableFuture实战指南
1. 问题场景解析一个子任务要依赖两个父任务完成才能执行这个需求在实际开发中非常常见。比如电商系统中的订单支付流程可能需要同时满足库存校验和风控审核两个前置条件才能执行支付操作。这种多依赖关系在分布式系统、批处理任务、工作流引擎等场景下尤为普遍。我最近在重构一个物流调度系统时就遇到了类似问题车辆路径规划子任务必须等待订单数据准备完成和路况信息更新完成两个父任务都执行完毕才能启动。下面分享几种经过实战验证的解决方案。2. 基础解决方案对比2.1 轮询检查法最朴素的实现方式是让子任务定期检查父任务状态while(true) { if (parent1.isDone() parent2.isDone()) { executeChildTask(); break; } Thread.sleep(1000); // 每秒检查一次 }注意这种方式会浪费CPU资源且响应延迟取决于轮询间隔。适合对实时性要求不高的后台任务。2.2 回调嵌套法通过回调函数的嵌套来实现依赖parent1.execute(() - { parent2.execute(() - { childTask.execute(); }); });这种写法在JavaScript中很常见但在Java中会导致回调地狱。当依赖层级变多时代码可读性会急剧下降。3. CompletableFuture 解决方案3.1 核心API介绍Java 8的CompletableFuture提供了更优雅的解决方案CompletableFutureVoid parent1 CompletableFuture.runAsync(...); CompletableFutureVoid parent2 CompletableFuture.runAsync(...); CompletableFuture.allOf(parent1, parent2) .thenRun(() - { // 子任务逻辑 });allOf()方法会等待所有给定的Future完成然后触发后续操作。相比轮询方案这种实现没有资源浪费且代码更加简洁。3.2 超时控制增强版实际项目中建议添加超时控制CompletableFuture.allOf(parent1, parent2) .orTimeout(30, TimeUnit.SECONDS) .exceptionally(ex - { log.error(任务超时, ex); return null; }) .thenRun(this::executeChildTask);4. 生产环境注意事项4.1 任务编排可视化对于复杂依赖关系建议使用有向无环图(DAG)来建模。可以使用Graphviz生成可视化图表digraph G { parent1 - child parent2 - child }这样在排查问题时可以快速理清任务关系。4.2 分布式场景处理在微服务架构中父任务可能分布在不同的服务中。这时可以采用事件驱动架构父任务完成后发布事件子任务订阅相关事件工作流引擎如Camunda、Activiti等数据库状态标记使用数据库记录任务状态5. 性能优化技巧5.1 并行化父任务确保父任务之间没有依赖时可以并行执行CompletableFutureVoid parent1 CompletableFuture.runAsync(...); CompletableFutureVoid parent2 CompletableFuture.runAsync(...); // 会自动并行执行5.2 线程池隔离不同类型的任务应该使用不同的线程池避免相互影响ExecutorService ioPool Executors.newFixedThreadPool(10); ExecutorService cpuPool Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); CompletableFutureVoid parent1 CompletableFuture.runAsync(ioTask, ioPool); CompletableFutureVoid parent2 CompletableFuture.runAsync(cpuTask, cpuPool);6. 常见问题排查6.1 任务卡死现象子任务一直不执行 排查步骤检查父任务是否有未捕获的异常查看线程池是否已满确认没有循环依赖6.2 性能瓶颈现象整体执行时间过长 优化方向分析父任务是否可以进一步拆分并行检查IO密集型任务是否使用了合适的线程池考虑使用缓存减少重复计算7. 设计模式应用7.1 观察者模式可以通过观察者模式实现松耦合的任务通知public class ParentTask { private ListChildTask observers new ArrayList(); public void addObserver(ChildTask observer) { observers.add(observer); } protected void notifyObservers() { observers.forEach(ChildTask::onParentComplete); } }7.2 状态模式对于复杂的状态转换可以使用状态模式interface TaskState { void checkCanExecute(); } class WaitingState implements TaskState { public void checkCanExecute() { if (parent1.isDone() parent2.isDone()) { context.setState(new ExecutingState()); } } }8. 测试方案设计8.1 单元测试要点测试多任务依赖时需要注意模拟父任务的不同完成顺序测试父任务超时场景验证异常传播机制示例测试用例Test void shouldExecuteChildAfterBothParentsComplete() { CompletableFutureVoid parent1 new CompletableFuture(); CompletableFutureVoid parent2 new CompletableFuture(); AtomicBoolean childExecuted new AtomicBoolean(false); CompletableFuture.allOf(parent1, parent2) .thenRun(() - childExecuted.set(true)); assertFalse(childExecuted.get()); parent1.complete(null); assertFalse(childExecuted.get()); parent2.complete(null); assertTrue(childExecuted.get()); }9. 扩展思考9.1 动态依赖关系某些场景下依赖关系可能是动态确定的。这时可以使用ListCompletableFuture? dependencies getDynamicDependencies(); CompletableFuture.allOf(dependencies.toArray(new CompletableFuture[0])) .thenRun(...);9.2 部分成功处理有时我们可能希望部分父任务失败时仍执行子任务CompletableFutureVoid parent1 CompletableFuture.runAsync(...); CompletableFutureVoid parent2 CompletableFuture.runAsync(...); parent1.exceptionally(ex - null); parent2.exceptionally(ex - null); CompletableFuture.allOf(parent1, parent2) .thenRun(...);10. 其他语言实现10.1 JavaScript实现在Node.js中可以使用PromisePromise.all([parent1, parent2]) .then(() childTask());10.2 Python实现Python 3.5提供了类似的语法async def main(): await asyncio.gather(parent1(), parent2()) child_task()11. 日志与监控11.1 关键日志点建议在以下位置添加日志每个父任务开始/完成时子任务触发条件满足时超时或异常发生时11.2 监控指标需要监控的关键指标父任务执行时间分布子任务等待时间任务依赖关系图的状态12. 架构设计建议对于企业级系统建议使用专门的工作流引擎管理复杂依赖实现任务持久化支持断点续跑设计任务优先级机制提供任务可视化监控界面我在实际项目中发现当依赖关系超过3层时就应该考虑引入工作流引擎了。最近使用Camunda实现的一个订单处理流程包含了17个相互依赖的任务节点通过BPMN可视化设计器大大提高了可维护性。
)
