Type Alias ISemaphoreBase

Type declaration

• acquire:function

  • acquire(): ITask<boolean>

  • The acquire method acquires an slots only if the slot limit is not reached.

    Returns ITask<boolean>

    Returns true if the slot limit is not reached otherwise false is returned.

• acquireBlocking:function

  • acquireBlocking(settings?: SemaphoreAquireBlockingSettings): ITask<boolean>

  • The acquireBlocking method acquires an slots only if the slot limit is not reached. If the slot limit is reached, it retries every settings.interval until settings.time is reached.

    Parameters

    • Optionalsettings: SemaphoreAquireBlockingSettings

    Returns ITask<boolean>

    Returns true if the slot limit is not reached otherwise false is returned.

• acquireBlockingOrFail:function

  • acquireBlockingOrFail(settings?: SemaphoreAquireBlockingSettings): ITask<void>

  • The acquireBlockingOrFail method acquires an slots only if the slot limit is not reached. If the slot limit is reached, it retries every settings.interval until settings.time is reached. Throws an error if the slot limit is reached after the given settings.time.

    Parameters

    • Optionalsettings: SemaphoreAquireBlockingSettings

    Returns ITask<void>

    Throws

    LimitReachedSemaphoreError

• acquireOrFail:function

  • acquireOrFail(): ITask<void>

  • The acquireOrFail method acquires an slots only if the slot limit is not reached. Throws an error if the slot limit is reached.

    Returns ITask<void>

    Throws

    LimitReachedSemaphoreError

• forceReleaseAll:function

  • forceReleaseAll(): ITask<boolean>

  • The forceReleaseAll method releases the all slots.

    Returns ITask<boolean>

    Returns true if the semaphore exists and has at least one unavailable slot or false if all slots are available.

• refresh:function

  • refresh(ttl?: ITimeSpan): ITask<boolean>

  • The refresh method updates the ttl of the slot when acquired.

    Parameters

    • Optionalttl: ITimeSpan

    Returns ITask<boolean>

    Returns true if the slot is refreshed otherwise false is returned.

• refreshOrFail:function

  • refreshOrFail(ttl?: ITimeSpan): ITask<void>

  • The refreshOrFail method updates the ttl of the slot when acquired. Throws an error if the slot is not acquired.

    Parameters

    • Optionalttl: ITimeSpan

    Returns ITask<void>

    Throws

    FailedRefreshSemaphoreError

• release:function

  • release(): ITask<boolean>

  • The release method releases the current slot.

    Returns ITask<boolean>

    Returns true if the semaphore exists and has at least one busy slot or false.

• releaseOrFail:function

  • releaseOrFail(): ITask<void>

  • The releaseOrFail method releases the current slot. Throws an error if the slot is not acquired.

    Returns ITask<void>

    Throws

    FailedReleaseSemaphoreError

• runBlockingOrFail:function

  • runBlockingOrFail<TValue = void>(
        asyncFn: AsyncLazy<TValue>,
        settings?: SemaphoreAquireBlockingSettings,
    ): ITask<TValue>

  • The runBlockingOrFail method wraps an Invokable or ITask with the acquireBlockingOrFail and release method.

    Type Parameters

    • TValue = void

    Parameters

    • asyncFn: AsyncLazy<TValue>
    • Optionalsettings: SemaphoreAquireBlockingSettings

    Returns ITask<TValue>

    Throws

    LimitReachedSemaphoreError

• runOrFail:function

  • runOrFail<TValue = void>(asyncFn: AsyncLazy<TValue>): ITask<TValue>

  • The runOrFail method wraps an Invokable or ITask with the acquireOrFail and release method.

    Type Parameters

    • TValue = void

    Parameters

    • asyncFn: AsyncLazy<TValue>

    Returns ITask<TValue>

    Throws

    LimitReachedSemaphoreError