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

Method Pause

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

ARROW_ENABLE_THREADING

Source from the content-addressed store, hash-verified

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

Callers 1

NextMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected