#include <readerwriterqueue.h>
Public Member Functions | |
BlockingReaderWriterQueue (size_t maxSize=15) | |
AE_FORCEINLINE bool | enqueue (T const &element) |
AE_FORCEINLINE bool | enqueue (T &&element) |
AE_FORCEINLINE T * | peek () |
AE_FORCEINLINE bool | pop () |
AE_FORCEINLINE size_t | size_approx () const |
template<typename U > | |
bool | try_dequeue (U &result) |
AE_FORCEINLINE bool | try_enqueue (T const &element) |
AE_FORCEINLINE bool | try_enqueue (T &&element) |
template<typename U > | |
void | wait_dequeue (U &result) |
template<typename U > | |
bool | wait_dequeue_timed (U &result, std::int64_t timeout_usecs) |
Private Types | |
typedef ::moodycamel::ReaderWriterQueue< T, MAX_BLOCK_SIZE > | ReaderWriterQueue |
Private Member Functions | |
BlockingReaderWriterQueue (ReaderWriterQueue const &) | |
BlockingReaderWriterQueue & | operator= (ReaderWriterQueue const &) |
Private Attributes | |
ReaderWriterQueue | inner |
spsc_sema::LightweightSemaphore | sema |
Definition at line 690 of file readerwriterqueue.h.
|
private |
Definition at line 693 of file readerwriterqueue.h.
|
inlineexplicit |
Definition at line 696 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 848 of file readerwriterqueue.h.
|
inline |
Definition at line 729 of file readerwriterqueue.h.
|
inline |
Definition at line 742 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 851 of file readerwriterqueue.h.
|
inline |
Definition at line 819 of file readerwriterqueue.h.
|
inline |
Definition at line 827 of file readerwriterqueue.h.
|
inline |
Definition at line 841 of file readerwriterqueue.h.
|
inline |
Definition at line 756 of file readerwriterqueue.h.
|
inline |
Definition at line 703 of file readerwriterqueue.h.
|
inline |
Definition at line 716 of file readerwriterqueue.h.
|
inline |
Definition at line 771 of file readerwriterqueue.h.
|
inline |
Definition at line 787 of file readerwriterqueue.h.
|
private |
Definition at line 856 of file readerwriterqueue.h.
|
private |
Definition at line 857 of file readerwriterqueue.h.