start method

Future<void> start()

Start the worker pool

Implementation

Future<void> start() async {
  if (_isRunning) {
    throw StateError('Worker pool is already running');
  }

  _isRunning = true;

  // Create and start workers
  for (int i = 0; i < _workerCount; i++) {
    final worker = QueueWorker(_driver, _config);
    _workers.add(worker);

    // Start in background
    worker.start();
  }

  print('✅ Started worker pool with $_workerCount workers');
}