start method

@override Future<void> start()

Ensure at least ConcurrencySettings.minWorkers workers are started (defaulting to 1 if ConcurrencySettings.minWorkers is zero).

Implementation

@override
Future<void> start() {
  _stopped = false;
  final needs = _getProvisionNeeds(_queue.isEmpty ? 1 : _queue.length);
  return (needs > 0) ? _provisionWorkers(needs) : Future.value();
}