Source 生命周期

约 138 字小于 1 分钟

BaseSource.start() / stop() 是框架拥有的模板方法，子类只实现 on_start() 和 on_stop()。启动前由 SourceManager 注入 AppContext；启动失败会尝试回滚部分资源，停止失败则保留清理责任，允许后续重试。

Source 创建的 task、连接和线程必须由同一个 Source 保存并关闭。应用关闭时先停止生产者，再排空 EventBus，最后关闭 API，避免关闭途中继续产生事件。