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

Method Pause

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

ARROW_ENABLE_THREADING

Source from the content-addressed store, hash-verified

227
228#endif // ARROW_ENABLE_THREADING
229void SerialExecutor::Pause() {
230 // Same comment as SpawnReal above
231 auto state = state_;
232 {
233 std::lock_guard<std::mutex> lk(state->mutex);
234 state->paused = true;
235 }
236 state->wait_for_tasks.notify_one();
237}
238
239bool SerialExecutor::IsFinished() {
240 std::lock_guard<std::mutex> lk(state_->mutex);

Callers 1

NextMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected