Struct wasmer_vm::threadconditions::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 fn do_wait( &mut self, dst: NotifyLocation, timeout: Option<Duration>, ) -> Result<u32, WaiterError>

Add current thread to the waiter hash

pub fn do_notify(&mut self, dst: NotifyLocation, 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.