Method run

lib/workers.js:500–525

()

  }

  async run() {
    await this._ensureInitialized()
    recorder.startUnlessRunning()
    event.dispatcher.emit(event.workers.before)
    store.workerMode = true
    process.env.RUNS_WITH_WORKERS = 'true'

    // Create workers and set up message handlers immediately (not in recorder queue)
    // This prevents a race condition where workers start sending messages before handlers are attached
    const workerThreads = []
    for (const worker of this.workers) {
      const workerThread = createWorker(worker, this.isPoolMode)
      this._listenWorkerEvents(workerThread)
      workerThreads.push(workerThread)
    }

    recorder.add('workers started', () => {
      // Workers are already running, this is just a placeholder step
    })

    return new Promise(resolve => {
      this.on('end', () => {
        resolve()
      })
    })
  }

  /**
   * @returns {Array<WorkerObject>}