Struct tokio::runtime::blocking::pool::Inner

struct Inner {
    shared: Mutex<Shared>,
    condvar: Condvar,
    thread_name: Arc<dyn Fn() -> String + Send + Sync + 'static>,
    stack_size: Option<usize>,
    after_start: Option<Arc<dyn Fn() + Send + Sync>>,
    before_stop: Option<Arc<dyn Fn() + Send + Sync>>,
    thread_cap: usize,
    keep_alive: Duration,
    metrics: SpawnerMetrics,
}

Fields

shared: Mutex<Shared>

State shared between worker threads.

condvar: Condvar

Pool threads wait on this.

thread_name: Arc<dyn Fn() -> String + Send + Sync + 'static>

Spawned threads use this name.

stack_size: Option<usize>

Spawned thread stack size.

after_start: Option<Arc<dyn Fn() + Send + Sync>>

Call after a thread starts.

before_stop: Option<Arc<dyn Fn() + Send + Sync>>

Call before a thread stops.

thread_cap: usize

keep_alive: Duration

metrics: SpawnerMetrics

Implementations

impl Inner

fn run(&self, worker_thread_id: usize)