Struct wd_run::TaskEntity

pub struct TaskEntity { /* fields omitted */ }

Implementations

impl TaskEntity

pub fn new(t: TaskPoolType, cache: usize) -> TaskEntity

pub fn init(&self)

pub async fn init_task_pool(&'_ self)

pub async fn worker(
    receiver: Arc<SegQueue<Arc<dyn Task + 'static + Send + Sync>>>,
    now: Arc<AtomicU32>,
    status: Arc<AtomicBool>,
    max: u32,
    min: u32
)

pub fn make_worker(&self)

pub fn run(&self, f: Arc<dyn Task + 'static + Send + Sync>) -> usize

立即发送到执行队列，如果限定了max，则有可能造成堆积，导致内存暴增

pub async fn run_ease(&'_ self, f: Arc<dyn Task + 'static + Send + Sync>)

如果当前堆积任务过多超过预定闸值则缓解发送

pub fn close(&self)

立即停止任务，剩余任务不再执行

pub async fn close_timeout(&'_ self, timeout: Duration)

不再接受任务，处理完剩余任务后返回，或者超时返回