Function wakeupBatonSet

cachelib/common/inject_pause.cpp:48–62

}

size_t wakeupBatonSet(BatonSet& batonSet, size_t numThreads) {
  size_t numWaked = 0;
  if (numThreads == 0) {
    numThreads = batonSet.batons.size();
  }

  while (!batonSet.batons.empty() && numWaked < numThreads) {
    auto* b = batonSet.batons.front();
    batonSet.batons.pop_front();
    b->post();
    numWaked++;
  }

  return numWaked;
}

} // namespace