Options
All
  • Public
  • Public/Protected
  • All
Menu

Class WorkerTaskProcessor

Hierarchy

  • WorkerTaskProcessor

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

_workerUrl

_workerUrl: string

Optional initWorkerPromise

initWorkerPromise: Promise<void | Worker>

maxActiveTasks

maxActiveTasks: number

pendingQueue

pendingQueue: ObjectType[]

promiseMap

promiseMap: Map<number, { reject: any; resolve: any }>

taskId

taskId: number

waitingQueue

waitingQueue: ObjectType[]

Optional worker

worker: Worker

Methods

addTask

  • addTask(params: {}): void

  • Parameters

    • params: {}
      • [key: string]: unknown

    Returns void

completeTask

  • completeTask(data: { error?: Error; taskId: number }): void

  • Parameters

    • data: { error?: Error; taskId: number }
      • [key: string]: unknown
      • Optional error?: Error
      • taskId: number

    Returns void

createWorker

  • createWorker(): Promise<void | Worker>

  • Returns Promise<void | Worker>

destroyWorker

  • destroyWorker(): void

  • Returns void

handleWorker

  • handleWorker(worker: Worker, params: {}): Promise<unknown>

  • Parameters

    • worker: Worker
    • params: {}
      • [key: string]: unknown

    Returns Promise<unknown>

schedualTask

  • schedualTask(params: {}): Promise<unknown>

  • Parameters

    • params: {}
      • [key: string]: unknown

    Returns Promise<unknown>

startTask

  • startTask(): void

  • Returns void