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

Method co_enqueue

src/common/utils/BoundedQueue.h:29–33  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

27
28 template <typename U = T>
29 folly::coro::Task<void> co_enqueue(U &&item) {
30 co_await enqueueSemaphore_.co_wait();
31 queue_.writeIfNotFull(std::forward<U>(item));
32 dequeueSemaphore_.signal();
33 }
34
35 T dequeue() {
36 dequeueSemaphore_.wait();

Callers 4

enqueueMethod · 0.80
enqueueMethod · 0.80
enqueueMethod · 0.80
TESTFunction · 0.80

Calls 2

co_waitMethod · 0.45
signalMethod · 0.45

Tested by 1

TESTFunction · 0.64