priority-semaphore 0.1.3

Runtime-agnostic priority-aware async semaphore for Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use priority_semaphore::{PrioritySemaphore, TryAcquireError};
use std::sync::Arc;

fn main() {
    let sem = Arc::new(PrioritySemaphore::new(2));

    match sem.try_acquire(0) {
        Ok(_permit) => println!("first permit immediate"),
        Err(_) => println!("failed to acquire first permit"),
    }

    match sem.try_acquire(0) {
        Ok(_permit) => println!("second permit immediate"),
        Err(_) => println!("failed to acquire second permit"),
    }

    match sem.try_acquire(0) {
        Ok(_) => println!("unexpected third permit"),
        Err(TryAcquireError::NoPermits) => println!("no permits left"),
        Err(TryAcquireError::Closed) => unreachable!(),
    }
}