Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/cameron314/readerwriterqueue
/ functions
Functions
124 in github.com/cameron314/readerwriterqueue
⨍
Functions
124
◇
Types & classes
29
↓ 80 callers
Method
load
atomicops.h:285
↓ 27 callers
Method
enqueue
benchmarks/ext/1024cores/spscqueue.h:68
↓ 26 callers
Method
join
tests/common/simplethread.cpp:33
↓ 24 callers
Method
size_approx
tests/unittests/unittests.cpp:439
↓ 24 callers
Method
try_dequeue
tests/unittests/unittests.cpp:302
↓ 15 callers
Method
try_enqueue
tests/unittests/unittests.cpp:270
↓ 14 callers
Method
try_dequeue
returns 'false' if queue is empty
benchmarks/ext/1024cores/spscqueue.h:78
↓ 10 callers
Method
signal
atomicops.h:447
↓ 9 callers
Method
peek
tests/unittests/unittests.cpp:354
↓ 8 callers
Method
enqueue
benchmarks/bench.cpp:30
↓ 8 callers
Function
getSystemTime
benchmarks/systemtime.cpp:26
↓ 8 callers
Function
getTimeDelta
benchmarks/systemtime.cpp:38
↓ 6 callers
Function
inner_enqueue
readerwriterqueue.h:538
↓ 6 callers
Method
wait_dequeue_timed
readerwriterqueue.h:893
↓ 5 callers
Method
wait_dequeue
readerwriterqueue.h:876
↓ 4 callers
Method
try_pop
Pops the next element from the queue, if there is one. Thread-safe when called by consumer thread.
readerwritercircularbuffer.h:248
↓ 3 callers
Function
make_block
readerwriterqueue.h:728
↓ 3 callers
Method
max_capacity
tests/unittests/unittests.cpp:487
↓ 3 callers
Method
wait_enqueue
Blocks the current thread until there's enough space to enqueue the given item, then enqueues it (via copy). Thread-safe when called by producer threa
readerwritercircularbuffer.h:123
↓ 2 callers
Function
ceilToPow2
readerwriterqueue.h:654
↓ 2 callers
Method
emplace
tests/unittests/unittests.cpp:648
↓ 2 callers
Method
get_value
tests/unittests/unittests.cpp:66
↓ 2 callers
Function
load_consume
benchmarks/ext/1024cores/spscqueue.h:9
↓ 2 callers
Method
pop
tests/unittests/unittests.cpp:396
↓ 2 callers
Function
printTests
tests/unittests/unittests.cpp:840
↓ 2 callers
Method
run
tests/unittests/minitest.h:52
↓ 2 callers
Function
store_release
benchmarks/ext/1024cores/spscqueue.h:19
↓ 2 callers
Method
try_dequeue
readerwriterqueue.h:861
↓ 2 callers
Function
unpredictableDelay
tests/stabtest/stabtest.cpp:12
↓ 1 callers
Function
benchmarkName
benchmarks/bench.cpp:459
↓ 1 callers
Method
callCallback
tests/common/simplethread.h:23
↓ 1 callers
Function
ceilToPow2
Extracted from private static method of ReaderWriterQueue
tests/unittests/unittests.cpp:74
↓ 1 callers
Method
getAllTestNames
tests/unittests/minitest.h:45
↓ 1 callers
Function
signal
atomicops.h:747
↓ 1 callers
Method
timed_wait
atomicops.h:442
↓ 1 callers
Function
try_dequeue
readerwriterqueue.h:285
↓ 1 callers
Method
try_wait
atomicops.h:437
↓ 1 callers
Method
validateTestName
tests/unittests/minitest.h:40
↓ 1 callers
Method
wait_enqueue_timed
Blocks the current thread until there's enough space to enqueue the given item, or the timeout expires. Returns false without enqueueing the item if t
readerwritercircularbuffer.h:144
Method
ArgWrapper
tests/common/simplethread.h:21
Method
ArgWrapper
tests/common/simplethread.h:32
Method
ArgWrapper
tests/common/simplethread.h:42
Method
BlockingReaderWriterCircularBuffer
readerwritercircularbuffer.h:34
Method
BlockingReaderWriterCircularBufferAdapter
benchmarks/bench.cpp:29
Method
BlockingReaderWriterQueue
readerwriterqueue.h:765
Method
CallbackWrapper
tests/common/simplethread.h:63
Method
Foo
tests/unittests/unittests.cpp:21
Method
ProducerConsumerQueue
size must be >= 1.
benchmarks/ext/folly/ProducerConsumerQueue.h:44
Function
ReaderWriterQueue
Disable copying
readerwriterqueue.h:648
Method
ReaderWriterQueueTests
tests/unittests/unittests.cpp:92
Method
ReentrantGuard
readerwriterqueue.h:678
Method
Semaphore
atomicops.h:418
Method
SimpleThread
tests/common/simplethread.h:87
Method
ThreadProc
tests/common/simplethread.cpp:11
Method
ThreadRef
tests/common/simplethread.cpp:18
Method
UniquePtrWrapper
tests/unittests/unittests.cpp:64
Function
align_for
readerwriterqueue.h:669
Method
align_for
readerwritercircularbuffer.h:302
Method
alloc_node
benchmarks/ext/1024cores/spscqueue.h:114
Function
availableApprox
atomicops.h:758
Method
blocking
tests/unittests/unittests.cpp:504
Method
blocking_circular_buffer
tests/unittests/unittests.cpp:699
Method
callAndDelete
tests/common/simplethread.h:68
Method
callCallback
tests/common/simplethread.h:34
Method
callCallback
tests/common/simplethread.h:44
Method
callCallback
tests/common/simplethread.h:49
Method
create_empty_queue
tests/unittests/unittests.cpp:115
Method
demangle_type_name
tests/unittests/minitest.h:105
Method
destroy_count
tests/unittests/unittests.cpp:46
Method
destroyed_in_order
tests/unittests/unittests.cpp:47
Method
enqueue
benchmarks/ext/folly/ProducerConsumerQueue.h:75
Method
enqueue_many
tests/unittests/unittests.cpp:151
Method
enqueue_one
tests/unittests/unittests.cpp:128
Method
execTest
tests/unittests/minitest.h:83
Method
frontPtr
pointer to the value at the front of the queue (for use in-place) or nullptr if empty.
benchmarks/ext/folly/ProducerConsumerQueue.h:111
Method
inner_dequeue
readerwritercircularbuffer.h:280
Method
inner_enqueue
readerwritercircularbuffer.h:272
Method
inner_peek
readerwritercircularbuffer.h:289
Method
inner_pop
readerwritercircularbuffer.h:294
Method
isEmpty
benchmarks/ext/folly/ProducerConsumerQueue.h:133
Method
isFull
benchmarks/ext/folly/ProducerConsumerQueue.h:138
Function
main
tests/stabtest/stabtest.cpp:19
Function
main
Basic test harness
tests/unittests/unittests.cpp:853
Function
main
benchmarks/bench.cpp:79
Function
max_capacity
Returns the total number of items that could be enqueued without incurring an allocation when this queue is empty. Safe to call from both the producer
readerwriterqueue.h:517
Method
max_capacity
Returns the total number of items that could be enqueued without incurring an allocation when this queue is empty. Safe to call from both the producer
readerwriterqueue.h:961
Method
max_capacity
Returns the maximum number of elements that this circular buffer can hold at once. Thread-safe.
readerwritercircularbuffer.h:265
Method
nonempty_destroy
tests/unittests/unittests.cpp:182
Method
notifyTestFailed
tests/unittests/minitest.h:35
Function
peek
Returns a pointer to the front element in the queue (the one that would be removed next by a call to `try_dequeue` or `pop`). If the queue appears emp
readerwriterqueue.h:384
Method
peek
Returns a pointer to the front element in the queue (the one that would be removed next by a call to `try_dequeue` or `pop`). If the queue appears emp
readerwriterqueue.h:926
Method
peek
Returns a pointer to the next element in the queue (the one that would be removed next by a call to `try_dequeue` or `try_pop`). If the queue appears
readerwritercircularbuffer.h:239
Method
popFront
queue must not be empty
benchmarks/ext/folly/ProducerConsumerQueue.h:121
Method
registerTest
tests/unittests/minitest.h:77
Method
reset
tests/unittests/unittests.cpp:45
Function
runBenchmark
benchmarks/bench.cpp:234
Method
sizeGuess
If called by consumer, then true size may be more (because producer may be adding items concurrently). If called by producer, then true size may be le
benchmarks/ext/folly/ProducerConsumerQueue.h:155
Function
size_approx
Returns the approximate number of items currently in the queue. Safe to call from both the producer and consumer threads.
readerwriterqueue.h:493
Method
size_approx
Returns a (possibly outdated) snapshot of the total number of elements currently in the buffer. Thread-safe.
readerwritercircularbuffer.h:258
Function
sleep
benchmarks/systemtime.cpp:21
next →
1–100 of 124, ranked by callers