Method ReapBackgroundTasks

getting-started/gke/index_gcs.cc:176–187

}

void MutationBatcher::ReapBackgroundTasks() {
  std::unique_lock lk(mu_);
  // Remove any tasks that have completed. This would not be needed if
  // we had a fully asynchronous `AsyncCommit()` function in Cloud Spanner.
  background_tasks_.erase(
      std::remove_if(background_tasks_.begin(), background_tasks_.end(),
                     [](auto& t) {
                       using namespace std::chrono_literals;
                       return t.wait_for(10ms) == std::future_status::ready;
                     }),
      background_tasks_.end());
}

void MutationBatcher::FlushIfNeeded(std::unique_lock<std::mutex> const& lk) {
  if (items_.size() >= kEfficientRowLimit) return Flush(lk);