MCPcopy Create free account
hub / github.com/apache/arrow / WaitForIdle

Method WaitForIdle

cpp/src/arrow/util/thread_pool.cc:522–525  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

520}
521
522void ThreadPool::WaitForIdle() {
523 std::unique_lock<std::mutex> lk(state_->mutex_);
524 state_->cv_idle_.wait(lk, [this] { return state_->tasks_queued_or_running_ == 0; });
525}
526
527ThreadPool::ThreadPool()
528 : sp_state_(std::make_shared<ThreadPool::State>()),

Callers 9

CheckScannerBackpressureFunction · 0.80
TEST_PFunction · 0.80
TEST_FFunction · 0.80
RunJoinMethod · 0.80
MakePrimedThreadPoolFunction · 0.80
TESTFunction · 0.80
TEST_FFunction · 0.80
TestStraddlingFunction · 0.80
~TaskGuardMethod · 0.80

Calls 1

emptyMethod · 0.45

Tested by 7

CheckScannerBackpressureFunction · 0.64
TEST_PFunction · 0.64
TEST_FFunction · 0.64
MakePrimedThreadPoolFunction · 0.64
TESTFunction · 0.64
TEST_FFunction · 0.64
TestStraddlingFunction · 0.64