MCPcopy Create free account
hub / github.com/alibaba/zvec / wait_stop

Method wait_stop

src/include/zvec/ailego/parallel/thread_queue.h:201–204  ·  view source on GitHub ↗

Wait until all threads stopped processing

Source from the content-addressed store, hash-verified

199
200 //! Wait until all threads stopped processing
201 void wait_stop(void) {
202 std::unique_lock<std::mutex> lock(wait_mutex_);
203 stopped_cond_.wait(lock, [this]() { return this->is_stopped(); });
204 }
205
206 //! Check if the pool is stopped
207 bool is_stopped(void) const {

Callers

nothing calls this directly

Calls 2

is_stoppedMethod · 0.95
waitMethod · 0.80

Tested by

no test coverage detected