Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
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
ioRingWorker
Method · 0.45
take
Method · 0.45
timedWait
Method · 0.45
run
Method · 0.45
run
Method · 0.45
TEST
Function · 0.45
Calls
2
co_wait
Method · 0.45
signal
Method · 0.45
Tested by
1
TEST
Function · 0.36