Struct LockedImpl 

struct LockedImpl {
    mutex: Mutex<LockedInner>,
    condvar: Condvar,
}

Single-mutex + condvar implementation.

Fields

mutex: Mutex<LockedInner>

condvar: Condvar

Implementations

impl LockedImpl

fn new(thread_mgmt_state: ThreadManagementState) -> LockedImpl

fn spawn_task<F>( &self, task: Task, metrics: &SpawnerMetrics, on_no_idle: F, ) -> Result<(), SpawnError>

where F: FnOnce(&mut ThreadManagementState) -> Result<(), SpawnError>,

Push a task and either notify an idle worker or invoke on_no_idle (which is responsible for spawning a new worker if possible).

fn run_worker( &self, metrics: &SpawnerMetrics, keep_alive: Duration, worker_thread_id: usize, ) -> Option<JoinHandle<()>>

Run a worker thread’s main loop.

fn begin_shutdown( &self, ) -> Option<(Option<JoinHandle<()>>, HashMap<usize, JoinHandle<()>>)>

Begin pool shutdown: set the shutdown flag, drop the shutdown sender, wake all waiting workers, and hand back the worker JoinHandles for the caller to join.