Pool

import { Pool } from "https://raw-githubusercontent-com.649446.xyz/ehsan2003/task-pool/main/mod.ts";

class Pool {

constructor(size: number);

private waitQueue: FIFOQueue<Deffered<void>>;

private workingCount: number;

private releaseFirstWaiter();

private async waitForAvailability();

public async exec<T>(task: Task<T>): Promise<T>;

public getPendingCount(): number;

public getSize(): number;

public getWorkingCount(): number;

}

§Constructors

new Pool(size: number)

waitQueue: FIFOQueue<Deffered<void>>

workingCount: number

releaseFirstWaiter() private

waitForAvailability() private

exec<T>(task: Task<T>): Promise<T>

getPendingCount(): number

getSize(): number

getWorkingCount(): number