Method Join

tensorflow/cc/training/prefetch_runner.cc:73–84

}

Status PrefetchRunner::Join() {
  for (size_t i = 0; i < thread_pool_.size(); i++) {
    if (thread_pool_[i] != nullptr && thread_pool_[i]->joinable())
      thread_pool_[i]->join();
  }

  if (cancel_thread_ != nullptr && cancel_thread_->joinable()) {
    cancel_thread_->join();
  }

  return Status::OK();
}

void PrefetchRunner::Run(size_t index) {
  Status status;