Struct AsyncProcessor

pub struct AsyncProcessor<T, O, P>
where
    T: Clone + Send + Sync + 'static,
    O: Clone + Send + Sync + 'static,
    P: TaskProcessor<T, O>,
{ /* private fields */ }

异步任务处理器 负责管理任务队列、并发处理和任务生命周期

• T: 任务类型
• O: 任务输出类型
• P: 任务处理器实现

Implementations

impl<T, O, P> AsyncProcessor<T, O, P>

where T: Clone + Send + Sync + 'static, O: Clone + Send + Sync + 'static, P: TaskProcessor<T, O>,

pub fn new(config: ProcessorConfig, processor: P) -> Self

创建新的异步任务处理器

pub async fn submit_task( &self, task: T, priority: u32, ) -> ForgeResult<(u64, Receiver<TaskResult<T, O>>)>

提交新任务到处理器 返回任务ID和用于接收处理结果的通道

pub async fn start(&mut self) -> Result<(), ProcessorError>

启动任务处理器 创建后台任务来处理队列中的任务

pub async fn shutdown(&mut self) -> Result<(), ProcessorError>

优雅地关闭处理器 等待所有正在处理的任务完成后再关闭

pub async fn get_state(&self) -> ProcessorState

获取处理器当前状态

pub async fn is_running(&self) -> bool

检查处理器是否正在运行

pub async fn get_stats(&self) -> ProcessorStats

Trait Implementations

impl<T, O, P> Drop for AsyncProcessor<T, O, P>

where T: Clone + Send + Sync + 'static, O: Clone + Send + Sync + 'static, P: TaskProcessor<T, O>,

实现Drop特征，确保处理器在销毁时能够发送关闭信号

注意：Drop 是同步的，无法等待异步任务完成。 建议在销毁前显式调用 shutdown().await 来确保优雅关闭。

fn drop(&mut self)

Executes the destructor for this type.