Struct WorkerLimiter 

struct WorkerLimiter {
    semaphore: Arc<Semaphore>,
    state: Mutex<WorkerLimitState>,
    active: AtomicU32,
}

Fields

semaphore: Arc<Semaphore>

state: Mutex<WorkerLimitState>

active: AtomicU32

Implementations

impl WorkerLimiter

fn new(limit: usize) -> Self

fn state(&self) -> MutexGuard<'_, WorkerLimitState>

async fn acquire(self: &Arc<Self>) -> Option<WorkerPermit>

fn set_limit(&self, limit: usize)

fn limit(&self) -> usize

Trait Implementations

impl Debug for WorkerLimiter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.