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

Method Offer

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

Source from the content-addressed store, hash-verified

100 /// (which typically means that the thread pool has already been shut down).
101 template <typename V>
102 bool Offer(V&& work) {
103 DCHECK(initialized_);
104 return work_queue_.BlockingPut(std::forward<V>(work));
105 }
106
107 /// Blocks until the work item is placed on the queue or the timeout expires. The
108 /// ThreadPool must be initialized before calling this method. The same requirements

Callers 15

OfferUpdateMethod · 0.80
AdmitQueryMethod · 0.80
UnregisterQueryMethod · 0.80
SessionMaintenanceMethod · 0.80
ExpireQueryMethod · 0.80
TESTFunction · 0.80
serveMethod · 0.80
CompleteWriteMethod · 0.80
ProcessCancelQueriesMethod · 0.80

Calls 2

BlockingPutMethod · 0.45

Tested by 3

OfferUpdateMethod · 0.64
TESTFunction · 0.64
TESTFunction · 0.64