Struct concurrency_traits::RawCustomAsyncMutex

pub struct RawCustomAsyncMutex<M, Q> { /* fields omitted */ }

A converter for turning a RawMutex into a RawAsyncMutex. Runs all operations on own task.

Implementations

impl<M, Q> RawCustomAsyncMutex<M, Q> where
    M: 'static + RawMutex + Send + Sync,
    Q: 'static + Queue<Item = RawCustomAsyncMutexMessage> + Send + Sync, 

pub fn new<TS>(
    raw_mutex: M,
    message_queue: Q,
    spawner: TS
) -> Result<(Self, TS::SpawnReturn), TS::SpawnError> where
    TS: ThreadSpawner, 

Creates a new RawCustomAsyncMutex from a RawMutex and a message queue.

Trait Implementations

impl<M: Debug, Q: Debug> Debug for RawCustomAsyncMutex<M, Q>

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

Formats the value using the given formatter.

impl<M, Q> RawAsyncMutex for RawCustomAsyncMutex<M, Q> where
    M: 'static + RawMutex + Send + Sync,
    Q: 'static + Queue<Item = RawCustomAsyncMutexMessage> + Send + Sync, 

type LockFuture = CompleteFuture

The future returned by RawAsyncMutex::lock_async

fn lock_async(&self) -> Self::LockFuture

Locks the mutex asynchronously

impl<M, Q> RawMutex for RawCustomAsyncMutex<M, Q> where
    M: 'static + RawMutex + Send + Sync,
    Q: 'static + Queue<Item = RawCustomAsyncMutexMessage> + Send + Sync, 

fn lock(&self)

Locks the mutex, blocking.

impl<M, Q> RawTryMutex for RawCustomAsyncMutex<M, Q> where
    M: 'static + RawMutex + Send + Sync,
    Q: 'static + Queue<Item = RawCustomAsyncMutexMessage> + Send + Sync, 

fn try_lock(&self) -> bool

Locks the mutex, non-blocking. Returns true if locked.

unsafe fn unlock(&self)

Safety