core/io.neuralheads.kmpworker.core/RateLimiter

RateLimiter

class RateLimiter(val maxConcurrent: Int)

Rate limiter for controlling concurrent task execution.

val config = KmpWorkerConfig.current()
val limiter = RateLimiter(maxConcurrent = 3)

// In task execution:
limiter.acquire()
try {
    doWork()
} finally {
    limiter.release()
}

Parameters

maxConcurrent

Maximum number of tasks that can execute simultaneously.

Constructors

RateLimiter

constructor(maxConcurrent: Int)

Properties

activeCount

val activeCount: Int

Number of currently executing tasks.

maxConcurrent

val maxConcurrent: Int

Functions

acquire

suspend fun acquire()

Acquires a permit, suspending if the limit is reached.

release

fun release()

Releases a permit.

withPermit

suspend fun <T> withPermit(block: suspend () -> T): T

Executes block within a rate-limited context.