23 lines
855 B
TypeScript
23 lines
855 B
TypeScript
|
import SemaphoreInterface from './SemaphoreInterface';
|
||
|
|
declare class Semaphore implements SemaphoreInterface {
|
||
|
|
private _value;
|
||
|
|
private _cancelError;
|
||
|
|
constructor(_value: number, _cancelError?: Error);
|
||
|
|
acquire(weight?: number, priority?: number): Promise<[number, SemaphoreInterface.Releaser]>;
|
||
|
|
runExclusive<T>(callback: SemaphoreInterface.Worker<T>, weight?: number, priority?: number): Promise<T>;
|
||
|
|
waitForUnlock(weight?: number, priority?: number): Promise<void>;
|
||
|
|
isLocked(): boolean;
|
||
|
|
getValue(): number;
|
||
|
|
setValue(value: number): void;
|
||
|
|
release(weight?: number): void;
|
||
|
|
cancel(): void;
|
||
|
|
private _dispatchQueue;
|
||
|
|
private _dispatchItem;
|
||
|
|
private _newReleaser;
|
||
|
|
private _drainUnlockWaiters;
|
||
|
|
private _couldLockImmediately;
|
||
|
|
private _queue;
|
||
|
|
private _weightedWaiters;
|
||
|
|
}
|
||
|
|
export default Semaphore;
|