Struct ThreadConditions

pub struct ThreadConditions {
    inner: Arc<NotifyMap>,
}

HashMap of Waiters for the Thread/Notify opcodes

Fields

inner: Arc<NotifyMap>

Implementations

impl ThreadConditions

pub fn new() -> Self

Create a new ThreadConditions

pub unsafe fn do_wait( &mut self, dst: NotifyLocation, expected: ExpectedValue, timeout: Option<Duration>, ) -> Result<u32, WaiterError>

Add current thread to the waiter hash

Safety

If expected is ExpectedValue::None, no safety requirements. The notify location must have a valid base address that belongs to a memory, and the address must be a valid offset within that memory. The offset also must be properly aligned for the expected value type; either 4-byte aligned for ExpectedValue::U32 or 8-byte aligned for ExpectedValue::U64.

pub fn do_notify(&mut self, dst: u32, count: u32) -> u32

Notify waiters from the wait list

pub fn wake_all_atomic_waiters(&self)

Wake all the waiters, without marking them as notified.

Useful on shutdown to resume execution in all waiters.

pub fn disable_atomics(&self)

Disable the use of atomics, leading to all atomic waits failing with an error, which leads to a Webassembly trap.

Useful for force-closing instances that keep waiting on atomics.

pub fn downgrade(&self) -> ThreadConditionsHandle

Get a weak handle to this ThreadConditions instance.

See ThreadConditionsHandle for more information.

Trait Implementations

impl Clone for ThreadConditions

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadConditions

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

Formats the value using the given formatter.