Add a Semaphore::count() method

This public method can be used to query the currently available concurrency in the semaphore without affecting its state.
neosmart · Oct 7, 2022 · a65b43b · a65b43b
1 parent 84e88ce
commit a65b43b
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/semaphore.rs b/src/semaphore.rs
@@ -373,6 +373,13 @@ impl Semaphore
 
         return true;
     }
+
+    /// Returns the currently available count of the semaphore.
+    ///
+    /// Note that this may race with other calls such as `release()` or `wait()`.
+    pub fn count(&self) -> Count {
+        self.count.load(Ordering::Relaxed)
+    }
 }
 
 impl<'a> Awaitable<'a> for Semaphore {