handleStop 处理停止
()
| 442 | |
| 443 | // handleStop 处理停止 |
| 444 | func (a *AgentActor) handleStop() { |
| 445 | a.mu.Lock() |
| 446 | a.isRunning = false |
| 447 | a.mu.Unlock() |
| 448 | |
| 449 | // 取消所有运行中的 goroutine |
| 450 | a.cancel() |
| 451 | |
| 452 | if err := a.agent.Close(); err != nil { |
| 453 | agentLog.Error(context.Background(), "agent actor close error", map[string]any{"agent_id": a.agent.ID(), "error": err}) |
| 454 | } |
| 455 | } |
| 456 | |
| 457 | // recordError 记录错误 |
| 458 | func (a *AgentActor) recordError(err error) { |