Function managed_worker

src/thread_pool.rs:2510–2519

This is the main loop for a worker thread. It's in charge of executing jobs. Operating on the principle that you should finish what you start before starting something new, workers will first execute their queue, then execute shared jobs, then pull new jobs from the injector.

(membership: Membership, halt: Arc<AtomicBool>)

    }
}

// -----------------------------------------------------------------------------
// Implicit worker registration api

/// A [`ThreadPool`] wrapper, used by the [`DEFAULT_POOL`].
///
/// This dereferences to a [`ThreadPool`]. The first time it is dereferenced, it
/// resizes itself to fill all available cores.
pub struct DefaultThreadPool {
    thread_pool: &'static ThreadPool,
    initialized: AtomicU32,
}