Struct Thread

pub struct Thread { /* private fields */ }

The state for the thread pool thread for the currently running CPU.

Implementations

impl Thread

pub fn current() -> Option<Self>

Returns an instance for the current CPU.

pub fn with_driver<R>(&self, f: impl FnOnce(&ThreadpoolDriver) -> R) -> R

Calls f with the driver for the current thread.

pub fn set_idle_task<F>(&self, f: F)

where F: 'static + Send + AsyncFnOnce(IdleControl),

Sets the idle task to run. The task is returned by f, which receives the file descriptor of the IO ring.

The idle task is run before waiting on the IO ring. The idle task can block synchronously by first calling [IdleControl::pre_block], and then by polling on the IO ring while the task blocks.

pub fn try_set_affinity(&self) -> Result<bool, SetAffinityError>

Tries to set the affinity to this thread’s intended CPU, if it has not already been set. Returns Ok(false) if the intended CPU is still offline.

pub fn first_task(&self) -> Option<TaskInfo>

Returns the that caused this thread to spawn.

Returns None if the thread was spawned to issue IO.

Trait Implementations

impl Clone for Thread

fn clone(&self) -> Thread

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Thread

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

Formats the value using the given formatter.

impl SpawnLocal for Thread

fn scheduler_local(&self, metadata: &TaskMetadata) -> Arc<dyn Schedule>

Gets a scheduler for a new task.

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

where T: 'static, Self: Sized,

Spawns a task.

impl Copy for Thread