Interface Spawn

src/thread_pool.rs:466–485

A trait for types that can be spawned onto a [`ThreadPool`]. It is implemented for: Closures that satisfy `for<'worker> FnOnce(&'worker Worker) + Send + 'static`. Futures that satisfy `Future + Send + 'static` where `T: Send + 'static`. Closures return `()` when spawned, but futures return a [`Task`]. # Compile Errors Due to a bug in rustc, you may be given errors when using clos

    where
        F: FnOnce(&Worker) -> R,
    {
        self.get_worker(|worker| match worker {
            Some(worker) => func(worker),
            None => self.with_worker_cold(func),
        })
    }

    /// The cold branch of `with_worker`.
    ///
    /// Requests membership in the thread pool, and then activates that
    /// membership to get a new local worker handle. If the thread pool is full
    /// (there are already 32 members) this blocks.
    #[cold]
    fn with_worker_cold<F, R>(&'static self, func: F) -> R
    where
        F: FnOnce(&Worker) -> R,
    {
        let membership = self.enroll();
        membership.activate(func)
    }
}

// -----------------------------------------------------------------------------