Lawtext core references / core/src/data/workersPool / WorkersPool

Class: WorkersPool<TInput, TResult>

Defined in: core/src/data/workersPool.ts:7

Type Parameters

TInput

TInput

TResult

TResult

Constructors

Constructor

protected new WorkersPool<TInput, TResult>(workersCount, fileName, workerOptions, workers): WorkersPool<TInput, TResult>

Defined in: core/src/data/workersPool.ts:10

Parameters

workersCount

number

fileName

string | URL

workerOptions

WorkerOptions | undefined

workers

Map<number, Worker>

Returns

WorkersPool<TInput, TResult>

Properties

fileName

fileName: string | URL

Defined in: core/src/data/workersPool.ts:12

promises

protected promises: Map<number, Promise<[number, number, TInput, TResult]>>

Defined in: core/src/data/workersPool.ts:8

workerOptions

workerOptions: WorkerOptions | undefined

Defined in: core/src/data/workersPool.ts:13

workers

workers: Map<number, Worker>

Defined in: core/src/data/workersPool.ts:14

workersCount

workersCount: number

Defined in: core/src/data/workersPool.ts:11

Methods

run()

run(items): AsyncIterable<[number, TInput, TResult]>

Defined in: core/src/data/workersPool.ts:47

Parameters

items

AsyncIterable<TInput>

Returns

AsyncIterable<[number, TInput, TResult]>

unref()

unref(): void

Defined in: core/src/data/workersPool.ts:75

Returns

void

initialize()

static initialize<TInput, TResult>(workersCount, fileName, workerOptions?): Promise<WorkersPool<TInput, TResult>>

Defined in: core/src/data/workersPool.ts:17

Type Parameters

TInput

TInput

TResult

TResult

Parameters

workersCount

number

fileName

string | URL

workerOptions?

WorkerOptions

Returns

Promise<WorkersPool<TInput, TResult>>