Struct Pool 

pub struct Pool {
    pub worker_num: i32,
    pub idle: (Sender<Option<Task>>, Receiver<Option<Task>>),
    /* private fields */
}

an coroutines pool

Fields

worker_num: i32

idle: (Sender<Option<Task>>, Receiver<Option<Task>>)

Implementations

impl Pool

pub fn new(worker_num: i32) -> Self

pub fn new_bounded(worker_num: i32, waiter_num: i32) -> Self

pub fn put(&self, task: Task)

pub fn close(&self)

close just now

pub fn close_finish(&self)

close when all task finish

pub fn is_close(&self) -> bool

pub fn run(&self)

Trait Implementations

impl Drop for Pool

fn drop(&mut self)

Executes the destructor for this type.