Struct RocketMQTokioMutex

pub struct RocketMQTokioMutex<T: ?Sized> { /* private fields */ }

Implementations

impl<T: ?Sized> RocketMQTokioMutex<T>

pub fn new(data: T) -> Self

where T: Sized,

Creates a new RocketMQTokioMutex instance containing the given data.

Arguments

• data - The data to be protected by the mutex.

Returns

A new RocketMQTokioMutex instance.

pub async fn lock(&self) -> MutexGuard<'_, T>

Acquires the lock asynchronously, blocking the current task until it is able to do so.

Returns

A MutexGuard that releases the lock when dropped.

pub async fn try_lock(&self) -> Option<MutexGuard<'_, T>>

Attempts to acquire the lock asynchronously without blocking.

Returns

An Option containing a MutexGuard if the lock was successfully acquired, or None if the lock is already held.

pub async fn try_lock_timeout( &self, timeout: Duration, ) -> Option<MutexGuard<'_, T>>

Attempts to acquire the lock asynchronously, blocking for up to the specified timeout.

Arguments

• timeout - The maximum duration to wait for the lock.

Returns

An Option containing a MutexGuard if the lock was successfully acquired within the timeout, or None if the timeout expired.

Trait Implementations

impl<T> Default for RocketMQTokioMutex<T>

where T: Default,

fn default() -> Self

Returns the “default value” for a type.