Lawtext core references / core/src/data/workersPool / WorkersPool
Class: WorkersPool<TInput, TResult>
core/src/data/workersPool.WorkersPool
Type parameters
| Name |
|---|
TInput |
TResult |
Table of contents
Constructors
Properties
Methods
Constructors
constructor
• new WorkersPool<TInput, TResult>(workersCount, fileName, workerOptions, workers): WorkersPool<TInput, TResult>
Type parameters
| Name |
|---|
TInput |
TResult |
Parameters
| Name | Type |
|---|---|
workersCount | number |
fileName | string | URL |
workerOptions | undefined | WorkerOptions |
workers | Map<number, Worker> |
Returns
WorkersPool<TInput, TResult>
Defined in
core/src/data/workersPool.ts:9 (opens in a new tab)
Properties
fileName
• fileName: string | URL
Defined in
core/src/data/workersPool.ts:11 (opens in a new tab)
promises
• Protected promises: Map<number, Promise<[workerIndex: number, itemIndex: number, input: TInput, result: TResult]>>
Defined in
core/src/data/workersPool.ts:7 (opens in a new tab)
workerOptions
• workerOptions: undefined | WorkerOptions
Defined in
core/src/data/workersPool.ts:12 (opens in a new tab)
workers
• workers: Map<number, Worker>
Defined in
core/src/data/workersPool.ts:13 (opens in a new tab)
workersCount
• workersCount: number
Defined in
core/src/data/workersPool.ts:10 (opens in a new tab)
Methods
run
▸ run(items): AsyncIterable<[itemIndex: number, input: TInput, result: TResult]>
Parameters
| Name | Type |
|---|---|
items | AsyncIterable<TInput> |
Returns
AsyncIterable<[itemIndex: number, input: TInput, result: TResult]>
Defined in
core/src/data/workersPool.ts:46 (opens in a new tab)
unref
▸ unref(): void
Returns
void
Defined in
core/src/data/workersPool.ts:74 (opens in a new tab)
initialize
▸ initialize<TInput, TResult>(workersCount, fileName, workerOptions?): Promise<WorkersPool<TInput, TResult>>
Type parameters
| Name |
|---|
TInput |
TResult |
Parameters
| Name | Type |
|---|---|
workersCount | number |
fileName | string | URL |
workerOptions? | WorkerOptions |
Returns
Promise<WorkersPool<TInput, TResult>>