Struct CancellationMap 

pub struct CancellationMap { /* private fields */ }

任务取消追踪结构 Task cancellation tracking structure

对应 Go asynq 的 internal/base/base.go 中的 Cancellations Corresponds to Cancellations in Go asynq’s internal/base/base.go

Implementations

impl CancellationMap

pub fn new() -> Self

创建新的 Cancellations 实例 Create a new Cancellations instance

pub fn add(&self, task_id: String, token: CancellationToken)

添加任务取消令牌 Add task cancellation token

pub fn remove(&self, task_id: &str)

移除任务取消令牌 Remove task cancellation token

pub fn cancel(&self, task_id: &str) -> bool

取消指定的任务 Cancel specified task

对应 Go 的 cancelations.Cancel(taskID) Corresponds to Go’s cancelations.Cancel(taskID)

pub fn len(&self) -> usize

获取正在运行的任务数量 Get the number of running tasks

pub fn is_empty(&self) -> bool

检查是否为空 Check if empty

Trait Implementations

impl Clone for CancellationMap

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CancellationMap

fn default() -> Self

Returns the “default value” for a type.