Struct TaskQueue

pub struct TaskQueue<T, O>
where
    T: Send + Sync,
    O: Send + Sync,
{ /* private fields */ }

任务队列结构

• queue: 任务发送通道
• queue_rx: 任务接收通道（包装在Arc中以支持共享访问）
• next_task_id: 下一个任务的ID（原子递增）
• stats: 任务处理器统计信息

Implementations

impl<T: Clone + Send + Sync + 'static, O: Clone + Send + Sync + 'static> TaskQueue<T, O>

pub fn new(config: &ProcessorConfig) -> Self

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

pub async fn get_next_ready( &self, ) -> Option<(T, u64, Sender<TaskResult<T, O>>, u32, u32)>

pub async fn get_stats(&self) -> ProcessorStats

pub async fn update_stats(&self, result: &TaskResult<T, O>)