Method Close

pkg/events/bus.go:156–185

Close 关闭事件总线，释放资源

()

// Close 关闭事件总线，释放资源
func (eb *EventBus) Close() {
	// 先停止清理 worker（不持锁，避免死锁）
	if eb.cleanupDone != nil {
		close(eb.cleanupDone)
		eb.cleanupWg.Wait() // 等待清理 goroutine 完全退出
		eb.cleanupDone = nil
	}

	// 然后清理所有资源（持锁）
	eb.mu.Lock()
	defer eb.mu.Unlock()

	// 关闭所有订阅 channel
	for id, ch := range eb.progressSubs {
		close(ch)
		delete(eb.progressSubs, id)
	}
	for id, ch := range eb.controlSubs {
		close(ch)
		delete(eb.controlSubs, id)
	}
	for id, ch := range eb.monitorSubs {
		close(ch)
		delete(eb.monitorSubs, id)
	}

	// 清空数据
	eb.timeline = nil
	eb.bookmarks = nil
}

// emit 发送事件到总线(内部方法)
func (eb *EventBus) emit(channel types.AgentChannel, event any) types.AgentEventEnvelope {