kresil-lib/kresil.ratelimiter.semaphore.state/InMemorySemaphoreState

InMemorySemaphoreState

internal class InMemorySemaphoreState : SemaphoreState(source)

Represents an in-memory state of a semaphore.

Constructors

constructor()

Properties

permitsInUse

open override var permitsInUse: Int

The number of permits currently in use (i.e., permits that have been acquired but not yet released).

queue

internal val queue: CircularDoublyLinkedList<RateLimitedRequest>

The queue to store the requests that are waiting for permits to be available.

replenishmentTimeMark

open override var replenishmentTimeMark: ComparableTimeMark

The time mark indicating when the semaphore state was last replenished. It is used to determine when the rate limiting replenishment period has passed.

Functions

open override fun close()

setPermits

open override fun setPermits(updateFunction: (Int) -> Int)

Updates the number of permits optionally considering the current value.

setReplenishmentTimeMark

open override fun setReplenishmentTimeMark(value: ComparableTimeMark)

Sets a new replenishment time mark by essentially taking a snapshot of the current time.