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

Method co_dequeue

src/common/utils/BoundedQueue.h:43–49  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

41 }
42
43 folly::coro::Task<T> co_dequeue() {
44 co_await dequeueSemaphore_.co_wait();
45 T item;
46 queue_.readIfNotEmpty(item);
47 enqueueSemaphore_.signal();
48 co_return item;
49 }
50
51 void dequeue(T &item) {
52 dequeueSemaphore_.wait();

Callers 6

ioRingWorkerMethod · 0.45
takeMethod · 0.45
timedWaitMethod · 0.45
runMethod · 0.45
runMethod · 0.45
TESTFunction · 0.45

Calls 2

co_waitMethod · 0.45
signalMethod · 0.45

Tested by 1

TESTFunction · 0.36