Struct tokio::task::local::Shared

struct Shared {
    local_state: LocalState,
    queue: Mutex<Option<VecDeque<Notified<Arc<Shared>>>>>,
    waker: AtomicWaker,
}

LocalSet state shared between threads.

Fields

local_state: LocalState

Safety

This field must only be accessed from the thread that owns the LocalSet (i.e., Thread::current().id() == owner).

queue: Mutex<Option<VecDeque<Notified<Arc<Shared>>>>>

Remote run queue sender.

waker: AtomicWaker

Wake the LocalSet task.

Implementations

impl Shared

fn schedule(&self, task: Notified<Arc<Self>>)

Schedule the provided task on the scheduler.

fn ptr_eq(&self, other: &Shared) -> bool

Trait Implementations

impl Sync for Shared