Struct tokio_util::loom::sync::ReentrantLock

pub struct ReentrantLock<T>
where
    T: ?Sized,
{
    mutex: Mutex,
    owner: Tid,
    lock_count: UnsafeCell<u32>,
    data: T,
}

🔬This is a nightly-only experimental API. (reentrant_lock)

A re-entrant mutual exclusion lock

This lock will block other threads waiting for the lock to become available. The thread which has already locked the mutex can lock it multiple times without blocking, preventing a common source of deadlocks.

Examples

Allow recursively calling a function needing synchronization from within a callback (this is how StdoutLock is currently implemented):

#![feature(reentrant_lock)]

use std::cell::RefCell;
use std::sync::ReentrantLock;

pub struct Log {
    data: RefCell<String>,
}

impl Log {
    pub fn append(&self, msg: &str) {
        self.data.borrow_mut().push_str(msg);
    }
}

static LOG: ReentrantLock<Log> = ReentrantLock::new(Log { data: RefCell::new(String::new()) });

pub fn with_log<R>(f: impl FnOnce(&Log) -> R) -> R {
    let log = LOG.lock();
    f(&*log)
}

with_log(|log| {
    log.append("Hello");
    with_log(|log| log.append(" there!"));
});

Fields

mutex: Mutex

🔬This is a nightly-only experimental API. (reentrant_lock)

owner: Tid

🔬This is a nightly-only experimental API. (reentrant_lock)

lock_count: UnsafeCell<u32>

🔬This is a nightly-only experimental API. (reentrant_lock)

data: T

🔬This is a nightly-only experimental API. (reentrant_lock)

Implementations

impl<T> ReentrantLock<T>

pub const fn new(t: T) -> ReentrantLock<T>

🔬This is a nightly-only experimental API. (reentrant_lock)

Creates a new re-entrant lock in an unlocked state ready for use.

Examples

#![feature(reentrant_lock)]
use std::sync::ReentrantLock;

let lock = ReentrantLock::new(0);

pub fn into_inner(self) -> T

🔬This is a nightly-only experimental API. (reentrant_lock)

Consumes this lock, returning the underlying data.

Examples

#![feature(reentrant_lock)]

use std::sync::ReentrantLock;

let lock = ReentrantLock::new(0);
assert_eq!(lock.into_inner(), 0);

impl<T> ReentrantLock<T>

where T: ?Sized,

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

🔬This is a nightly-only experimental API. (reentrant_lock)

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

This function will block the caller until it is available to acquire the lock. Upon returning, the thread is the only thread with the lock held. When the thread calling this method already holds the lock, the call succeeds without blocking.

Examples

#![feature(reentrant_lock)]
use std::cell::Cell;
use std::sync::{Arc, ReentrantLock};
use std::thread;

let lock = Arc::new(ReentrantLock::new(Cell::new(0)));
let c_lock = Arc::clone(&lock);

thread::spawn(move || {
    c_lock.lock().set(10);
}).join().expect("thread::spawn failed");
assert_eq!(lock.lock().get(), 10);

pub fn get_mut(&mut self) -> &mut T

🔬This is a nightly-only experimental API. (reentrant_lock)

Returns a mutable reference to the underlying data.

Since this call borrows the ReentrantLock mutably, no actual locking needs to take place – the mutable borrow statically guarantees no locks exist.

Examples

#![feature(reentrant_lock)]
use std::sync::ReentrantLock;

let mut lock = ReentrantLock::new(0);
*lock.get_mut() = 10;
assert_eq!(*lock.lock(), 10);

Trait Implementations

impl<T> Debug for ReentrantLock<T>

where T: Debug + ?Sized,

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

Formats the value using the given formatter.

impl<T> Default for ReentrantLock<T>

where T: Default,

fn default() -> ReentrantLock<T>

Returns the “default value” for a type.

impl<T> From<T> for ReentrantLock<T>

fn from(t: T) -> ReentrantLock<T>

Converts to this type from the input type.

impl<T> RefUnwindSafe for ReentrantLock<T>

where T: RefUnwindSafe + ?Sized,

impl<T> Send for ReentrantLock<T>

where T: Send + ?Sized,

impl<T> Sync for ReentrantLock<T>

where T: Send + ?Sized,

impl<T> UnwindSafe for ReentrantLock<T>

where T: UnwindSafe + ?Sized,