Class AsyncSemaphore

Author: Alexandru Nedelcu (@alexandru) From: https://alexn.org/blog/2020/04/21/javascript-semaphore.html#isso-thread From (archived): https://web.archive.org/web/20201127022014/https://alexn.org/blog/2020/04/21/javascript-semaphore.html

Hierarchy

AsyncSemaphore

Index

Constructors

Properties

_available _completeFn _completePr _heads _upcoming workersCount

Methods

_acquire _execWithRelease _queue _refreshComplete _release awaitTerminate withLock withLockRunAndForget

Constructors

constructor

new AsyncSemaphore(workersCount: number): AsyncSemaphore
Parameters
- workersCount: number
Returns AsyncSemaphore
- Defined in AsyncSemaphore.ts:15

Properties

`Private` _available

_available: number

`Private` _completeFn

_completeFn: (() => void)

Type declaration

- (): void
- Returns void

`Private` _completePr

_completePr: Promise<void>

`Private` _heads

_heads: (() => void)[]

`Private` _upcoming

_upcoming: (() => void)[]

`Readonly` workersCount

workersCount: number

Methods

`Private` _acquire

_acquire(): void | Promise<void>
Returns void | Promise<void>
- Defined in AsyncSemaphore.ts:56

`Private` _execWithRelease

_execWithRelease<A>(f: (() => Promise<A>)): Promise<A>
Type Parameters
- A
Parameters
- f: (() => Promise<A>)
  - - (): Promise<A>
    - Returns Promise<A>
Returns Promise<A>
- Defined in AsyncSemaphore.ts:40

`Private` _queue

_queue(): (() => void)[]
Returns (() => void)[]
- Defined in AsyncSemaphore.ts:48

`Private` _refreshComplete

_refreshComplete(): void
Returns void
- Defined in AsyncSemaphore.ts:84

`Private` _release

_release(): void
Returns void
- Defined in AsyncSemaphore.ts:68

awaitTerminate

awaitTerminate(): Promise<void>
Returns Promise<void>
- Defined in AsyncSemaphore.ts:34

withLock

withLock<A>(f: (() => Promise<A>)): Promise<A>
Type Parameters
- A
Parameters
- f: (() => Promise<A>)
  - - (): Promise<A>
    - Returns Promise<A>
Returns Promise<A>
- Defined in AsyncSemaphore.ts:23

withLockRunAndForget

withLockRunAndForget<A>(f: (() => Promise<A>)): Promise<void>
Type Parameters
- A
Parameters
- f: (() => Promise<A>)
  - - (): Promise<A>
    - Returns Promise<A>
Returns Promise<void>
- Defined in AsyncSemaphore.ts:28

Generated using TypeDoc