Class ThreadManager

Private Readonly available

Private Readonly busy

Private Readonly client

Private Readonly executing

Private increment

Private maxWorkerCount

Private Readonly queue

Private workerCount

• get workerCount(): number

• Returns number

Private enqueue

• enqueue(task): Promise<void>

• Parameters

  • task: IThreadTask

  Returns Promise<void>

Private execute

• execute(): Promise<void>

• Returns Promise<void>

Private getAvailableWorker

• getAvailableWorker(): Promise<undefined | Worker>

• Returns Promise<undefined | Worker>

Private getNextTaskId

• getNextTaskId(): number

• Returns number

Private onWorkerError

• onWorkerError(worker, err): Promise<void>

• Parameters

  • worker: Worker

  • err: Error

  Returns Promise<void>

Private onWorkerExit

• onWorkerExit(worker, code): Promise<void>

• Parameters

  • worker: Worker

  • code: number

  Returns Promise<void>

Private onWorkerMessage

• onWorkerMessage(worker, msg): Promise<void>

• Parameters

  • worker: Worker

  • msg: IThreadResult

  Returns Promise<void>

Private setAvailableWorker

• setAvailableWorker(worker): void

• Parameters

  • worker: Worker

  Returns void

Private setBusyWorker

• setBusyWorker(worker): void

• Parameters

  • worker: Worker

  Returns void