在 LangGraph 中实现任务的并行执行(Fan-out)和结果汇总(Fan-in)非常直观。根据你的需求,主要有两种实现方式: 1. 静态并行(Static Parallelism):分支数量和节点是固定的(例如:同时调用“分析情感”节点和“提取实体”节点,然后汇总)。 2. 动态并行(Dynamic Parallelism / Map-Reduce):分支数量根据输入数据动态决定(例如:输入包含 $N$ 篇文章,并行启动 $N$ 个节点处理,最后汇总)。 下面我将分别用代码示例详细讲解这两种场景的实现方法。 --- 场景一:静态并行(固定分支 Fan-out / Fan-in) 在 LangGraph 中,如果你将同一个源节点连接到多个目标节点,LangGraph 会自动并行执行这些目标节点。 同样,如果多个节点都指向同一个下游节点,下游节点会等待它们全部执行完毕后再触发(隐式的 Barrier/Wait)。 关键点: 状态(State)设计时,并行节点写入的字段必须相互独立,或者使用 (如 ),以防止结果被互相覆盖。 代码示例: --- 场景二:动态并行(Map-Red...