MCPcopy Create free account
hub / github.com/catboost/catboost / Dequeue

Method Dequeue

library/cpp/threading/chunk_queue/queue.h:266–274  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

264 }
265
266 bool Dequeue(T& value) {
267 size_t index = 0;
268 if (TEntry* entry = PrepareRead(index)) {
269 value = TTypeHelper::Read(&entry->Value);
270 Queues[index].CompleteRead();
271 return true;
272 }
273 return false;
274 }
275
276 bool IsEmpty() {
277 for (size_t i = 0; i < Concurrency; ++i) {

Callers

nothing calls this directly

Calls 2

CompleteReadMethod · 0.80
ReadFunction · 0.50

Tested by

no test coverage detected