Struct AffinitizedThreadpool

pub struct AffinitizedThreadpool { /* private fields */ }

A pool of affinitized worker threads.

Implementations

impl AffinitizedThreadpool

pub fn new(io_ring_size: u32) -> Result<Self>

Creates a new threadpool with the specified ring size.

pub fn current_driver(&self) -> &ThreadpoolDriver

Returns an object that can be used to submit IOs or spawn tasks to the current processor’s ring.

Spawned tasks will remain affinitized to the current thread. Spawn directly on the threadpool object to get a task that will run on any thread.

pub fn driver(&self, ring_id: u32) -> &ThreadpoolDriver

Returns an object that can be used to submit IOs to the specified ring in the pool, or to spawn tasks on the specified thread.

Spawned tasks will remain affinitized to the specified thread. Spawn directly on the threadpool object to get a task that will run on any thread.

pub fn active_drivers(&self) -> impl Iterator<Item = &ThreadpoolDriver> + Clone

Returns an iterator of drivers for threads that are running and have their affinity set.

This is useful for getting a set of drivers that can be used to parallelize work.

Trait Implementations

impl Clone for AffinitizedThreadpool

fn clone(&self) -> AffinitizedThreadpool

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AffinitizedThreadpool

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

Formats the value using the given formatter.

impl Initiate for AffinitizedThreadpool

Initiate IOs to the current CPU’s thread.

fn initiator(&self) -> &IoInitiator

Returns a reference to the initiator to use for IO operations.

impl Inspect for AffinitizedThreadpool

fn inspect(&self, req: Request<'_>)

Inspects the object.

impl Spawn for AffinitizedThreadpool

fn scheduler(&self, _metadata: &TaskMetadata) -> Arc<dyn Schedule>

Gets a scheduler for a new task.

fn spawn<T>( &self, name: impl Into<Arc<str>>, fut: impl Future<Output = T> + Send + 'static, ) -> Task<T, TaskMetadata>

where T: 'static + Send, Self: Sized,

Spawns a task.