并行化（Parallelization）：让 AI 同时处理互不依赖的事

查新闻 -> 查财报 -> 查产品 -> 查用户评价 -> 汇总

如果任务之间只是在“收集不同材料”，通常可以并行。
如果任务之间是在“逐步推理和决策”，通常要谨慎。

[
  { "name": "news", "depends_on": [] },
  { "name": "finance", "depends_on": [] },
  { "name": "product", "depends_on": [] },
  { "name": "summary", "depends_on": ["news", "finance", "product"] }
]

1. 新闻动态
2. 经营数据
3. 产品信息
4. 用户口碑

可以并行：
新闻动态、经营数据、产品信息、用户口碑
 
不适合并行：
先总结报告，再基于总结写邮件

最多同时跑 3 个子任务；
单个任务超过 30 秒就标记 timeout；
失败结果不阻塞其他任务；

1000 条用户评论
  ↓
每 100 条一组并行分析
  ↓
汇总高频问题和代表性样例

输入：公司名称
输出：一份调研摘要，包含新闻、经营、产品、用户口碑和风险提示

{
  "topic": "news",
  "findings": ["..."],
  "risks": ["..."],
  "sources": ["..."],
  "status": "success"
}

你是一名公司研究分析师。
 
请根据下面四类并行调研结果，生成一份简明调研摘要。
 
要求：
1. 不要编造资料中没有的信息；
2. 合并重复结论；
3. 明确标出信息不足或子任务失败的部分；
4. 输出：核心判断、关键证据、风险、下一步建议。
 
并行结果：
{{parallel_results}}

import asyncio
 
 
async def run_one_task(task, semaphore):
    async with semaphore:
        try:
            output = await ai_call(task["prompt"], timeout=30)
            return {
                "name": task["name"],
                "status": "success",
                "output": output,
            }
        except TimeoutError:
            return {
                "name": task["name"],
                "status": "timeout",
                "output": None,
            }
        except Exception as error:
            return {
                "name": task["name"],
                "status": "failed",
                "error": str(error),
                "output": None,
            }
 
 
async def run_parallel_research(company):
    tasks = build_research_tasks(company)
    semaphore = asyncio.Semaphore(3)
 
    results = await asyncio.gather(
        *(run_one_task(task, semaphore) for task in tasks)
    )
 
    successful = [item for item in results if item["status"] == "success"]
    failed = [item for item in results if item["status"] != "success"]
 
    return await ai_call(
        prompt="请汇总调研结果，并说明失败或缺失的信息",
        input={
            "successful_results": successful,
            "failed_tasks": failed,
        },
    )

用户输入
  ↓
路由：判断任务类型
  ↓
并行化：同时收集互不依赖的材料
  ↓
提示词链：基于材料逐步生成、检查、改写

哪些任务真的互不依赖？
单个任务失败时怎么办？
多个结果回来后谁负责去重、取舍和汇总？