Struct ThreadpoolDriver

pub struct ThreadpoolDriver { /* private fields */ }

A driver for AffinitizedThreadpool that is targeted at a specific CPU.

Implementations

impl ThreadpoolDriver

pub fn target_cpu(&self) -> u32

Returns the target CPU number for this thread.

This may be different from the CPU tasks actually run on if the affinity has not yet been set for the thread.

pub fn is_affinity_set(&self) -> bool

Returns whether this thread’s CPU affinity has been set to the intended CPU.

pub async fn wait_for_affinity(&self)

Waits for the affinity to be set to this thread’s intended CPU. If the CPU was not online when the thread was created, then this will block until the CPU is online and someone calls try_set_affinity.

pub fn set_spawn_notifier<F: 'static + Send + FnOnce(bool)>( &self, f: F, ) -> Result<(), F>

Sets a function to be called when the thread gets spawned. The function accepts a single bool parameter that indicates that the notifier should cancel any oustanding run or not. When called by the threadpool, the function will recieve true.

Return Err(f) if the thread is already spawned.

Trait Implementations

impl Clone for ThreadpoolDriver

fn clone(&self) -> ThreadpoolDriver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadpoolDriver

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

Formats the value using the given formatter.

impl FdReadyDriver for ThreadpoolDriver

type FdReady = FdReady<ThreadpoolDriver>

The file descriptor ready type.

fn new_fd_ready(&self, fd: RawFd) -> Result<Self::FdReady>

Returns a new object for polling file descriptor readiness.

impl Initiate for ThreadpoolDriver

fn initiator(&self) -> &IoInitiator

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

impl Inspect for ThreadpoolDriver

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

Inspects the object.

impl Spawn for ThreadpoolDriver

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.

impl TimerDriver for ThreadpoolDriver

type Timer = Timer<ThreadpoolDriver>

The timer type.

fn new_timer(&self) -> Self::Timer

Returns a new timer.

impl WaitDriver for ThreadpoolDriver

type Wait = FdWait<ThreadpoolDriver>

The wait object.

fn new_wait(&self, fd: RawFd, read_size: usize) -> Result<Self::Wait>

Creates a new wait.