Struct rayon_core::latch::SpinLatch

pub(crate) struct SpinLatch<'r> {
    core_latch: CoreLatch,
    registry: &'r Arc<Registry>,
    target_worker_index: usize,
    cross: bool,
}

Spin latches are the simplest, most efficient kind, but they do not support a wait() operation. They just have a boolean flag that becomes true when set() is called.

Fields

core_latch: CoreLatch

registry: &'r Arc<Registry>

target_worker_index: usize

cross: bool

Implementations

impl<'r> SpinLatch<'r>

pub(crate) fn new(thread: &'r WorkerThread) -> SpinLatch<'r>

Creates a new spin latch that is owned by thread. This means that thread is the only thread that should be blocking on this latch – it also means that when the latch is set, we will wake thread if it is sleeping.

pub(crate) fn cross(thread: &'r WorkerThread) -> SpinLatch<'r>

Creates a new spin latch for cross-threadpool blocking. Notably, we need to make sure the registry is kept alive after setting, so we can safely call the notification.

pub(crate) fn probe(&self) -> bool

Trait Implementations

impl<'r> AsCoreLatch for SpinLatch<'r>

fn as_core_latch(&self) -> &CoreLatch

impl<'r> Latch for SpinLatch<'r>

unsafe fn set(this: *const Self)

Set the latch, signalling others.