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, ) -> Result<(u64, Receiver<TaskResult<T, O>>), ProcessorError>

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

pub fn start(&mut self)

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

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

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

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特征，确保处理器在销毁时能够优雅关闭

fn drop(&mut self)

Executes the destructor for this type.