Struct concurrency_traits::mutex::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
) -> Result<(Self, TS::ThreadHandle), TS::SpawnError> where
    TS: TryThreadSpawner<()>, 

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, 

fn lock_async<'life0, 'async_trait>(
    &'life0 self
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

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