ParallelFlow

May 15, 2026 · View on GitHub


该类在类层次结构中的位置:

[Oxy](../agent/base_oxy.md)
├── [BaseFlow](../agent/base_flow.md)
│   ├── [Workflow](./workflow.md)
│   ├── [ParallelFlow](./parallel_flow.md)
│   ├── [PlanAndSolve](./plan_and_solve.md)
│   ├── [Reflexion](./reflexion.md)
│   │   └── [MathReflexion](./reflexion.md)
│   └── [BaseAgent](../agent/base_agent.md)
├── [BaseLLM](../llms/base_llm.md)
└── [BaseTool](../tools/base_tools.md)

简介

ParallelFlow 是一个并发执行多个工具或智能体的 Flow。它使用 asyncio.gather 协调所有被允许的工具同时对同一请求进行并发执行,并将各自的结果汇总为统一的响应。

参数

参数类型 / 允许值默认值描述
无新增参数----ParallelFlow 未添加新字段;所有内容均继承自 BaseFlow

方法

方法协程 (async)返回值用途(简述)
_execute(oxy_request)OxyResponse在所有被允许的工具上并发执行请求并汇总结果。

继承

请参阅 BaseFlow 类了解继承的参数和方法。

用法

oxy.ParallelFlow(
    name="parallel_eval",
    desc="Run multiple agents in parallel",
    permitted_tool_name_list=["agent_a", "agent_b", "agent_c"],
)