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

Method Enqueue

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

Source from the content-addressed store, hash-verified

148
149 template <typename TT>
150 void Enqueue(TT&& value) {
151 T* ptr = PrepareWrite();
152 Y_ASSERT(ptr);
153 TTypeHelper::Write(ptr, std::forward<TT>(value));
154 CompleteWrite();
155 }
156
157 bool Dequeue(T& value) {
158 if (T* ptr = PrepareRead()) {

Callers 8

with_lockMethod · 0.45
TryEnqueueMethod · 0.45
TryEnqueueMethod · 0.45
EnqueueMethod · 0.45
Y_UNIT_TESTFunction · 0.45
~TImplMethod · 0.45
HostWorkerThreadMethod · 0.45
ExecMethod · 0.45

Calls 1

WriteFunction · 0.50

Tested by

no test coverage detected