Struct parking_lot_core::thread_parker::imp::ThreadParker

pub struct ThreadParker {
    futex: AtomicI32,
}

Fields

futex: AtomicI32

Implementations

impl ThreadParker

fn futex_wait(&self, ts: Option<timespec>)

Trait Implementations

impl ThreadParkerT for ThreadParker

type UnparkHandle = UnparkHandle

const IS_CHEAP_TO_CONSTRUCT: bool = true

fn new() -> ThreadParker

unsafe fn prepare_park(&self)

Prepares the parker. This should be called before adding it to the queue.

unsafe fn timed_out(&self) -> bool

Checks if the park timed out. This should be called while holding the queue lock after park_until has returned false.

unsafe fn park(&self)

Parks the thread until it is unparked. This should be called after it has been added to the queue, after unlocking the queue.

unsafe fn park_until(&self, timeout: Instant) -> bool

Parks the thread until it is unparked or the timeout is reached. This should be called after it has been added to the queue, after unlocking the queue. Returns true if we were unparked and false if we timed out.

unsafe fn unpark_lock(&self) -> UnparkHandle

Locks the parker to prevent the target thread from exiting. This is necessary to ensure that thread-local ThreadData objects remain valid. This should be called while holding the queue lock.