MCPcopy Create free account
hub / github.com/deepseek-ai/3FS / dequeue

Method dequeue

src/common/utils/BoundedQueue.h:35–41  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

33 }
34
35 T dequeue() {
36 dequeueSemaphore_.wait();
37 T item;
38 queue_.readIfNotEmpty(item);
39 enqueueSemaphore_.signal();
40 return item;
41 }
42
43 folly::coro::Task<T> co_dequeue() {
44 co_await dequeueSemaphore_.co_wait();

Callers 9

workerMethod · 0.45
actorMethod · 0.45
runMethod · 0.45
runMethod · 0.45
flushMethod · 0.45
getOrCreateWriterMethod · 0.45
allocateSlowMethod · 0.45
TESTFunction · 0.45
TESTFunction · 0.45

Calls 2

waitMethod · 0.45
signalMethod · 0.45

Tested by 2

TESTFunction · 0.36
TESTFunction · 0.36