Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
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
worker
Method · 0.45
actor
Method · 0.45
run
Method · 0.45
run
Method · 0.45
flush
Method · 0.45
getOrCreateWriter
Method · 0.45
allocateSlow
Method · 0.45
TEST
Function · 0.45
TEST
Function · 0.45
Calls
2
wait
Method · 0.45
signal
Method · 0.45
Tested by
2
TEST
Function · 0.36
TEST
Function · 0.36