Struct EventEngine 

pub struct EventEngine { /* private fields */ }

事件引擎。Send + Sync:可被 Arc 共享于多线程。

Implementations

impl EventEngine

pub fn new() -> Self

新引擎,默认定时间隔 1s(对齐原版 interval: int = 1)。

pub fn with_interval(interval: Duration) -> Self

自定义定时间隔。

pub fn start(&self)

启动分发线程与定时线程;已启动 / 已 stop 时为空操作(幂等)。 可从任意线程调用。

pub fn put(&self, event: Event) -> Result<(), PutError>

投递事件。start 前投递合法(事件入队,start 后分发,对齐原版); 已 stop / 通道断开时返回 PutError::Stopped。

pub fn register(&self, event_type: impl Into<String>, f: HandlerFn) -> HandlerId

注册 event_type 精确 handler,返回 HandlerId 供注销。 event_type 接受 &str / String / format!(...) 结果(对齐原版 str 语义)。

pub fn unregister(&self, id: HandlerId) -> bool

注销任意位置的 handler;true 表示确实注销了某个。

pub fn register_general(&self, f: HandlerFn) -> HandlerId

注册通用 handler(收所有事件)。

pub fn unregister_general(&self, id: HandlerId) -> bool

注销通用 handler。

pub fn is_active(&self) -> bool

引擎是否在运行。

pub fn pending_events(&self) -> u64

已入队、尚未分发完的事件数(近似)。 使用方在 stop 前想要“等排空“,轮询此处归零即可; stop 会强制清零(残余事件按“丢弃“语义不再计数)。

pub fn stop(&self)

停止引擎并 join 两线程;幂等,可从任意线程调用。 队列残余事件被丢弃(对齐原版);stop 后引擎不可重启。

Trait Implementations

impl Default for EventEngine

fn default() -> Self

Returns the “default value” for a type.