Method scheduleWork

src/master/pool.ts:217–231

()

  private scheduleWork() {
    this.debug(`Attempt de-queueing a task in order to run it...`)

    const availableWorker = this.findIdlingWorker()
    if (!availableWorker) return

    const nextTask = this.taskQueue.shift()
    if (!nextTask) {
      this.debug(`Task queue is empty`)
      this.eventSubject.next({ type: PoolEventType.taskQueueDrained })
      return
    }

    this.run(availableWorker, nextTask)
  }

  private taskCompletion(taskID: number) {
    return new Promise<any>((resolve, reject) => {