Class LimitedThreadPool

This is not really generic but written especially for the benchmarking script. It offers a work stealing thread pool executor.

Index

Constructors

Methods

Constructors

constructor

new LimitedThreadPool(
    module: string,
    queue: WorkingQueue,
    limit: number,
    parallel: number,
    timeLimitInMs?: number,
): LimitedThreadPool
Create a new parallel helper that runs the given module once for each list of Arguments in the queue. The limit stops the execution if <limit> number of runs exited successfully. The parallel parameter limits the number of parallel executions.
Parameters
- module: string
- queue: WorkingQueue
- limit: number
- parallel: number
- OptionaltimeLimitInMs: number
Returns LimitedThreadPool
- Defined in src/util/parallel.ts:34

Methods

getStats

getStats(): { counter: number; skipped: Arguments[] }
Returns { counter: number; skipped: Arguments[] }
- Defined in src/util/parallel.ts:55

run

run(): Promise<void>
Returns Promise<void>
- Defined in src/util/parallel.ts:42