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

Method enqueue

src/common/utils/BoundedQueue.h:22–26  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

20
21 template <typename U = T>
22 void enqueue(U &&item) {
23 enqueueSemaphore_.wait();
24 queue_.writeIfNotFull(std::forward<U>(item));
25 dequeueSemaphore_.signal();
26 }
27
28 template <typename U = T>
29 folly::coro::Task<void> co_enqueue(U &&item) {

Callers 4

addWithPriorityMethod · 0.45
setCoroutinesNumMethod · 0.45
removeMethod · 0.45

Calls 2

waitMethod · 0.45
signalMethod · 0.45

Tested by

no test coverage detected