Struct EventBus 

pub struct EventBus<T: Send + Sync + Clone + 'static> { /* private fields */ }

高性能事件总线

使用以下优化策略：

• ArcSwap 实现无锁读取事件处理器列表
• DashMap 用于快速查找和管理事件处理器
• 原子计数器生成唯一 ID
• 批量事件处理优化

Implementations

impl<T: Send + Sync + Clone + 'static> EventBus<T>

pub fn add_event_handler( &self, event_handler: Arc<dyn EventHandler<T> + Send + Sync>, ) -> ForgeResult<HandlerId>

添加事件处理器，返回处理器 ID

pub fn add_event_handlers( &self, event_handlers: Vec<Arc<dyn EventHandler<T> + Send + Sync>>, ) -> ForgeResult<Vec<HandlerId>>

批量添加事件处理器

pub fn remove_event_handler(&self, handler_id: HandlerId) -> ForgeResult<bool>

移除事件处理器

pub fn remove_event_handlers( &self, handler_ids: &[HandlerId], ) -> ForgeResult<usize>

批量移除事件处理器

pub fn handler_count(&self) -> usize

获取当前活跃的处理器数量

pub fn clear_handlers(&self) -> ForgeResult<()>

清空所有事件处理器

pub async fn destroy(&self) -> ForgeResult<()>

异步销毁事件总线

pub fn destroy_blocking(&self)

同步销毁事件总线（仅在非异步上下文中使用）

⚠️ 警告：此方法可能阻塞，应优先使用 destroy() 异步版本

pub fn start_event_loop(&self)

启动事件循环

pub fn new() -> Self

pub fn with_config(config: EventConfig) -> Self

pub fn subscribe(&self) -> Receiver<T>

pub async fn broadcast(&self, event: T) -> ForgeResult<()>

pub fn broadcast_blocking(&self, event: T) -> ForgeResult<()>

同步广播事件（仅在非异步上下文中使用）

⚠️ 警告：此方法可能阻塞当前线程，应优先使用 broadcast() 异步版本

使用场景

• 在 Drop 实现中
• 在同步的测试代码中
• 在非异步的回调函数中

示例

// 在异步上下文中，优先使用：
// event_bus.broadcast(event).await?;

// 仅在必要时使用阻塞版本：
event_bus.broadcast_blocking(event)?;

pub fn get_config(&self) -> &EventConfig

获取事件配置

pub fn update_config(&mut self, config: EventConfig)

更新事件配置（注意：某些配置更改需要重启事件循环才能生效）

pub fn get_stats(&self) -> EventBusStats

获取事件总线统计信息

pub fn reset_stats(&self)

重置统计信息

pub fn get_performance_report(&self) -> EventBusPerformanceReport

获取详细的性能报告

Trait Implementations

impl<T: Send + Sync + Clone + 'static> Clone for EventBus<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Send + Sync + Clone + 'static> Default for EventBus<T>

fn default() -> Self

Returns the “default value” for a type.