Struct DelayedTask 

pub struct DelayedTask<T: Send + Sync + Clone + 'static> {
    pub id: TaskId,
    pub name: String,
    pub execute_at: DateTime<Utc>,
    pub priority: u32,
    pub data: T,
    pub created_at: DateTime<Utc>,
}

延迟任务

Fields

id: TaskId

任务 ID

name: String

任务名称

execute_at: DateTime<Utc>

执行时间

priority: u32

优先级 (数值越小优先级越高)

data: T

任务数据

created_at: DateTime<Utc>

创建时间

Implementations

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

pub fn new(name: String, execute_at: DateTime<Utc>, data: T) -> Self

创建新的延迟任务

pub fn with_priority(self, priority: u32) -> Self

设置优先级

pub fn is_due(&self) -> bool

检查是否到期

pub fn remaining(&self) -> Duration

获取剩余时间

Trait Implementations

impl<T: Clone + Send + Sync + Clone + 'static> Clone for DelayedTask<T>

fn clone(&self) -> DelayedTask<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Send + Sync + Clone + 'static> Debug for DelayedTask<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.