Class WorkerPool

constructor

• new WorkerPool(minWorkers: number, maxWorkers: number): WorkerPool

  Parameters

  • minWorkers: number
  • maxWorkers: number

  Returns WorkerPool

ReadonlymaxWorkers

ReadonlyminWorkers

workerId

numFreeWorkers

• get numFreeWorkers(): number

  Returns number

numInitializingWorkers

• get numInitializingWorkers(): number

  Returns number

cancelJob

• cancelJob(id: number): void

  Parameters

  • id: number

  Returns void

ping

• ping<X>(value: X, waitMs: number): Promise<PingData>

  Type Parameters

  • X

  Parameters

  • value: X
  • waitMs: number

  Returns Promise<PingData>

setSheet

• setSheet(sheet: GearPlanSheet): Promise<void>

  Parameters

  • sheet: GearPlanSheet

  Returns Promise<void>

setWorkerProvider

• setWorkerProvider(provider: WorkerCreator): void

  Parameters

  • provider: WorkerCreator

  Returns void

submitTask

• submitTask<T extends AnyJobContext = never>(
      request: RequestTypeOf<T>,
      updateCallback?: JobUpdateCallback<T>,
  ): { jobId: number; promise: Promise<ResponseTypeOf<T>> }

  Type Parameters

  • T extends AnyJobContext = never

  Parameters

  • request: RequestTypeOf<T>
  • OptionalupdateCallback: JobUpdateCallback<T>

  Returns { jobId: number; promise: Promise<ResponseTypeOf<T>> }