Struct DelayedQueue 

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

延迟任务队列

管理延迟执行的任务，支持优先级排序。

Implementations

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

pub fn new<E: DelayedTaskExecutor<T> + 'static>( config: DelayedQueueConfig, executor: Arc<E>, ) -> Self

创建新的延迟任务队列

pub async fn schedule_delayed( &self, task: DelayedTask<T>, ) -> WaeResult<TaskHandle>

注册延迟任务

参数

• task: 延迟任务

返回值

返回任务句柄。

pub async fn queue_size(&self) -> usize

获取队列大小

pub async fn cancel_task(&self, task_id: &str) -> WaeResult<bool>

取消任务

pub async fn get_handle(&self, task_id: &str) -> Option<TaskHandle>

获取任务句柄

pub fn shutdown(&self)

关闭队列

pub fn is_shutdown(&self) -> bool

检查是否已关闭