============== 协调器 Actor ============== CoordinatorActor 工作流协调器 Actor 负责协调多个 Agent 的执行
| 243 | // CoordinatorActor 工作流协调器 Actor |
| 244 | // 负责协调多个 Agent 的执行 |
| 245 | type CoordinatorActor struct { |
| 246 | engine *ActorEngine |
| 247 | |
| 248 | // 运行中的工作流 |
| 249 | runningWorkflows map[string]*workflowState |
| 250 | mu sync.RWMutex |
| 251 | } |
| 252 | |
| 253 | type workflowState struct { |
| 254 | execution *WorkflowExecution |
nothing calls this directly
no outgoing calls
no test coverage detected