Struct SemaphoreKey

pub struct SemaphoreKey {}

The SemaphoreKey struct holds an implementation to be used to for the Semaphore by key functionality.

Implementations

impl SemaphoreKey

pub async fn get_or_create_semaphore( key: &String, allowed_concurrent_threads: usize, ) -> Arc<Semaphore>

Gets or creates a semaphore wrapped in an Arc by the provided key

Arguments

• key - The key to get an existing or create a new semaphore by

• allowed_concurrent_threads - Used when creating a new semaphore (if an existing one is not found by key), to specify how many concurrent threads are allowed access.

pub async fn remove_if_exists(key: &String) -> Option<Arc<Semaphore>>

Removes a semaphore from the internal map if it exists, and returns it wrapped in an Arc

Arguments

• key - The key to get an existing semaphore by