Struct blackhole::Blackhole

pub struct Blackhole<J> where
    J: Job,  { /* fields omitted */ }

Blackhole

Usage

You should call ::escape_on_idle() when done with this.

Be careful when you manually call ::drop() on a blackhole, or simply let it go out of scope. Because background threads are left unmanaged. They will keep running until main thread exits. Then they will be cancelled/discarded by the system.

Notes

• Messages printed by background threads are prefixed with TAG.
• About manager thread: to listen to runner threads' messages, at first, Receiver::recv_timeout() was considered. However there is a bug: #39364. So, currently Receiver::try_recv() is being used. After that, it sleeps for 1 millisecond. When above bug is fixed, we'll switch to ::recv_timeout().

Methods

impl<J> Blackhole<J> where
    J: Job, 

pub fn make(active_limit: ActiveLimit, queue_limit: usize) -> Result<Self>

Makes new instance

Notes

• Active limit and queue limit are declared in different types to help prevent typos.
• An error is returned if either active limit or queue limit is zero.
• Internal vectors used for jobs will be made immediately with capacities of active limit and queue limit.

pub fn throw(&self, job: J) -> Result<Option<J>>

Throws new job into the blackhole

• If the job is accepted, None is returned.
• If the job is not accepted, it is returned to you for recovery.

pub unsafe fn escape(self) -> Result<()>

Escapes the blackhole

Notes

• New jobs and all waiting jobs are discarded.
• Active jobs are left untouched. They will be discarded by system when the program's main thread exits.

pub fn escape_on_idle(self) -> Result<()>

Escapes the blackhole on idle and waits for it

Trait Implementations

impl<J: Debug> Debug for Blackhole<J> where
    J: Job, 

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

Formats the value using the given formatter.