Synchronous and Asynchronous Synchronization Primitives

Low-level synchronization primitives that provide both synchronous and asynchronous interfaces.

Features

• Asynchronous counterparts of synchronous methods.
• Loom support: features = ["loom"].
• No spin-locks and no busy loops.

Lock

saa::Lock is a Low-level shared-exclusive lock that provides both synchronous and asynchronous interfaces. Synchronous locking methods such as lock_exclusive_sync or lock_shared_sync can be used with their asynchronous counterparts, lock_exclusive_async or lock_shared_async, at the same time. saa::Lock implements a heap-allocation-free fair wait queue that is shared among both synchronous and asynchronous methods.

Examples

use saa::Lock;

let lock = Lock::default();

lock.lock_exclusive_sync();

assert!(!lock.try_lock_exclusive());
assert!(!lock.try_lock_shared());

assert!(!lock.unlock_shared());
assert!(lock.unlock_exclusive());

async {
    lock.lock_shared_async();
    assert!(lock.unlock_shared());
};

Semaphore

saa::Semaphore is a synchronization primitive that allows a fixed number of threads to access a resource concurrently.

Examples

use saa::Semaphore;

let semaphore = Semaphore::default();

semaphore.acquire_many_sync(Semaphore::MAX_PERMITS - 1);

assert!(semaphore.try_acquire());
assert!(!semaphore.try_acquire());

assert!(semaphore.release());
assert!(!semaphore.release_many(Semaphore::MAX_PERMITS));
assert!(semaphore.release_many(Semaphore::MAX_PERMITS - 1));

async {
    semaphore.acquire_async().await;
    assert!(semaphore.release());
};

Changelog