Method Schedule

be/src/kudu/util/threadpool.cc:261–266

Submit a task, running after delay_ms delay some time

// Submit a task, running after delay_ms delay some time
Status ThreadPoolToken::Schedule(std::function<void()> f, int64_t delay_ms) {
  CHECK(mode() == ThreadPool::ExecutionMode::SERIAL);
  MonoTime execute_time = MonoTime::Now();
  execute_time.AddDelta(MonoDelta::FromMilliseconds(delay_ms));
  return pool_->Schedule(this, std::move(f), execute_time);
}

void ThreadPoolToken::Wait() {
  MutexLock unique_lock(pool_->lock_);