Struct wd_event::task_pool::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 + Send + Sync + 'static>>>,
    now: Arc<AtomicU32>,
    status: Arc<AtomicBool>,
    max: u32,
    min: u32
)

pub fn make_worker(&self)

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

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

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

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

pub fn close(&self)

关闭任务池并将已存在的任务执行完毕