just 1.58.0

🤖 Just a command runner
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use super::*;

pub(crate) struct Semaphore(Condvar, Mutex<u64>);

pub(crate) struct Guard<'a>(&'a Semaphore);

impl Drop for Guard<'_> {
  fn drop(&mut self) {
    *self.0.mutex().lock().unwrap() += 1;
    self.0.condvar().notify_one();
  }
}

impl Semaphore {
  pub(crate) fn new(resource: NonZeroU64) -> Self {
    Self(Condvar::new(), Mutex::new(resource.into()))
  }

  fn condvar(&self) -> &Condvar {
    &self.0
  }

  fn mutex(&self) -> &Mutex<u64> {
    &self.1
  }

  pub(crate) fn acquire(&self) -> Guard {
    let mut count = self
      .condvar()
      .wait_while(self.mutex().lock().unwrap(), |count| *count == 0)
      .unwrap();

    *count -= 1;

    Guard(self)
  }
}