#include <readerwriterqueue.h>
Public Member Functions | |
BlockingReaderWriterQueue (size_t maxSize=15) AE_NO_TSAN | |
BlockingReaderWriterQueue (BlockingReaderWriterQueue &&other) AE_NO_TSAN | |
AE_FORCEINLINE bool | enqueue (T const &element) AE_NO_TSAN |
AE_FORCEINLINE bool | enqueue (T &&element) AE_NO_TSAN |
BlockingReaderWriterQueue & | operator= (BlockingReaderWriterQueue &&other) AE_NO_TSAN |
AE_FORCEINLINE T * | peek () AE_NO_TSAN |
AE_FORCEINLINE bool | pop () AE_NO_TSAN |
AE_FORCEINLINE size_t | size_approx () const AE_NO_TSAN |
template<typename U > | |
bool | try_dequeue (U &result) AE_NO_TSAN |
AE_FORCEINLINE bool | try_enqueue (T const &element) AE_NO_TSAN |
AE_FORCEINLINE bool | try_enqueue (T &&element) AE_NO_TSAN |
template<typename U > | |
void | wait_dequeue (U &result) AE_NO_TSAN |
template<typename U > | |
bool | wait_dequeue_timed (U &result, std::int64_t timeout_usecs) AE_NO_TSAN |
Private Types | |
typedef ::moodycamel::ReaderWriterQueue< T, MAX_BLOCK_SIZE > | ReaderWriterQueue |
Private Member Functions | |
BlockingReaderWriterQueue (BlockingReaderWriterQueue const &) | |
BlockingReaderWriterQueue & | operator= (BlockingReaderWriterQueue const &) |
Private Attributes | |
ReaderWriterQueue | inner |
std::unique_ptr< spsc_sema::LightweightSemaphore > | sema |
Definition at line 724 of file readerwriterqueue.h.
|
private |
Definition at line 727 of file readerwriterqueue.h.
|
inlineexplicit |
Definition at line 730 of file readerwriterqueue.h.
|
inline |
Definition at line 734 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 894 of file readerwriterqueue.h.
|
inline |
Definition at line 774 of file readerwriterqueue.h.
|
inline |
Definition at line 786 of file readerwriterqueue.h.
|
inline |
Definition at line 738 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 895 of file readerwriterqueue.h.
|
inline |
Definition at line 865 of file readerwriterqueue.h.
|
inline |
Definition at line 873 of file readerwriterqueue.h.
|
inline |
Definition at line 886 of file readerwriterqueue.h.
|
inline |
Definition at line 800 of file readerwriterqueue.h.
|
inline |
Definition at line 749 of file readerwriterqueue.h.
|
inline |
Definition at line 761 of file readerwriterqueue.h.
|
inline |
Definition at line 815 of file readerwriterqueue.h.
|
inline |
Definition at line 832 of file readerwriterqueue.h.
|
private |
Definition at line 898 of file readerwriterqueue.h.
|
private |
Definition at line 899 of file readerwriterqueue.h.