ranked-semaphore 0.1.0

A high-performance ranked semaphore with priority support
Documentation

ranked-semaphore

A priority-aware semaphore for async Rust.

Features

  • Priority scheduling: Configurable priority-based task ordering
  • No runtime dependency: Works with any async runtime (Tokio, async-std, smol, etc.)
  • Flexible queue strategies: FIFO/LIFO and custom rules per priority

Quick Start

use ranked_semaphore::RankedSemaphore;

#[tokio::main]
async fn main() {
    // Create a semaphore with 3 permits, FIFO strategy
    let sem = RankedSemaphore::new_fifo(3);

    // Acquire a permit (default priority)
    let permit = sem.acquire().await.unwrap();

    // Acquire with custom priority
    let high = sem.acquire_with_priority(10).await.unwrap();

    // Release permits automatically on drop
    drop(permit);
    drop(high);
}

Advanced Usage

Priority-based API Rate Limiting

use ranked_semaphore::{RankedSemaphore, PriorityConfig, QueueStrategy};
use std::sync::Arc;

let config = PriorityConfig::new()
    .default_strategy(QueueStrategy::Fifo)
    .exact(10, QueueStrategy::Lifo);

let limiter = Arc::new(RankedSemaphore::new_with_config(2, config));

let _admin = limiter.acquire_with_priority(10).await.unwrap();
let _guest = limiter.acquire_with_priority(0).await.unwrap();

Examples

運行：

cargo run -p tokio-example
cargo run -p async-std-example
cargo run -p smol-example
cargo run -p futures-example

License

MIT

Links