Method run

web/lib/performance/worker-pool.ts:45–56

(payload: unknown, transferables?: Transferable[])

  }

  run(payload: unknown, transferables?: Transferable[]): Promise<T> {
    return new Promise<T>((resolve, reject) => {
      this.ensureSlots();
      const task: WorkerTask<T> = { payload, resolve, reject, transferables };
      const slot = this.getFreeSlot();
      if (slot) {
        this.dispatch(slot, task);
      } else {
        this.queue.push(task);
      }
    });
  }

  private dispatch(slot: WorkerSlot, task: WorkerTask<T>): void {
    slot.busy = true;