Method start

src/emulator/workQueue.ts:65–96

* Begin processing work from the queue.

()

   * Begin processing work from the queue.
   */
  async start() {
    if (!this.stopped) {
      return;
    }

    this.stopped = false;
    while (!this.stopped) {
      // If the queue is empty, wait until something is added.
      if (!this.queue.length) {
        await new Promise<void>((res) => {
          this.notifyQueue = res;
        });
      }

      // If we have too many jobs out, wait until something finishes.
      if (this.running.length >= this.maxParallelWork) {
        this.logger.logLabeled(
          "DEBUG",
          "work-queue",
          `waiting for work to finish (running=${this.running})`,
        );
        await new Promise<void>((res) => {
          this.notifyWorkFinish = res;
        });
      }

      const workPromise = this.runNext();
      if (this.mode === FunctionsExecutionMode.SEQUENTIAL) {
        await workPromise;
      }
    }
  }

  /**
   * Stop processing work from the queue.