Creates a new semaphore object. The given Int32Array should be based on a SharedArrayBuffer, have length one and hold the number of currently availaber permits.
The typed array which holds the number of availabe permits. It has to have length of one and it has to be based on a SharedArrayBuffer.
Number of permits accuired by this instance.
The typed array which holds the number of availabe permits.
Number of permits acquired by this instance.
Number of currently available permits.
SharedArrayBuffer used by this semaphore.
Acquires a given number of permits from the semaphore. The call blocks untill enough permits are available and acquires all at once.
Number of permits to acquire.
Acquires a given number of permits from the semaphore. Calls to the function do not block like calls to acquire but immediately return with a promise. The promise resolves once all permis a available and acquired.
This should be used in favor of acquire if Atomics.wait is not available (eg. on the main thread).
Number of permits to acquire.
A promise that resolves once all permits are acquired.
Releases the given number of permits and returns them to the semaphore. It automatically notifies blocked acuire() and pending acquireAsync() calls.
Number of permits to release
Creates a new Semaphore initially holding the specified number of permits.
Intially availabe number of permits
Generated using TypeDoc
Conceptually a smaphore can be used to manage a set of permits across different thrads. The semaphore keeps track of how many permits are available. Each call to acquire() blocks untill enough permits are available and takes all at once. No longer needed permits can be released by calling release(). This notifies blocked acquire() calls.
This implementation uses Atomics and a SharedArrayBuffer which holds the number of availabe permits. To use a semaphore across multiple WebWorkers the SharedArrayBuffer can be shared to the Worker instances.