MCPcopy Create free account
hub / github.com/apache/impala / Shutdown

Method Shutdown

be/src/util/thread-pool.h:125–131  ·  view source on GitHub ↗

Shuts the thread pool down, causing the work queue to cease accepting offered work and the worker threads to terminate once they have processed their current work item. Returns once the shutdown flag has been set, does not wait for the threads to terminate.

Source from the content-addressed store, hash-verified

123 /// Returns once the shutdown flag has been set, does not wait for the threads to
124 /// terminate.
125 void Shutdown() {
126 {
127 std::lock_guard<std::mutex> l(lock_);
128 shutdown_ = true;
129 }
130 work_queue_.Shutdown();
131 }
132
133 /// Blocks until all threads are finished. Shutdown does not need to have been called,
134 /// since it may be called on a separate thread.

Callers 2

TESTFunction · 0.45
InserterThreadMethod · 0.45

Calls

no outgoing calls

Tested by 2

TESTFunction · 0.36
InserterThreadMethod · 0.36