#include <readerwriterqueue.h>
Public Member Functions | |
BlockingReaderWriterQueue (BlockingReaderWriterQueue &&other) AE_NO_TSAN | |
BlockingReaderWriterQueue (size_t size=15) AE_NO_TSAN | |
AE_FORCEINLINE bool | enqueue (T &&element) AE_NO_TSAN |
AE_FORCEINLINE bool | enqueue (T const &element) AE_NO_TSAN |
AE_FORCEINLINE size_t | max_capacity () const |
BlockingReaderWriterQueue & | operator= (BlockingReaderWriterQueue &&other) AE_NO_TSAN |
AE_FORCEINLINE T * | peek () const 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 &&element) AE_NO_TSAN |
AE_FORCEINLINE bool | try_enqueue (T const &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 791 of file readerwriterqueue.h.
|
private |
Definition at line 794 of file readerwriterqueue.h.
|
inlineexplicit |
Definition at line 797 of file readerwriterqueue.h.
|
inline |
Definition at line 802 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 977 of file readerwriterqueue.h.
|
inline |
Definition at line 856 of file readerwriterqueue.h.
|
inline |
Definition at line 843 of file readerwriterqueue.h.
|
inline |
Definition at line 970 of file readerwriterqueue.h.
|
inline |
Definition at line 807 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 980 of file readerwriterqueue.h.
|
inline |
Definition at line 934 of file readerwriterqueue.h.
|
inline |
Definition at line 942 of file readerwriterqueue.h.
|
inline |
Definition at line 956 of file readerwriterqueue.h.
|
inline |
Definition at line 870 of file readerwriterqueue.h.
|
inline |
Definition at line 830 of file readerwriterqueue.h.
|
inline |
Definition at line 817 of file readerwriterqueue.h.
|
inline |
Definition at line 885 of file readerwriterqueue.h.
|
inline |
Definition at line 902 of file readerwriterqueue.h.
|
private |
Definition at line 985 of file readerwriterqueue.h.
|
private |
Definition at line 986 of file readerwriterqueue.h.