#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 | sizeApprox () const |
template<typename U > | |
bool | tryDequeue (U &result) |
AE_FORCEINLINE bool | tryEnqueue (T const &element) |
AE_FORCEINLINE bool | tryEnqueue (T &&element) |
template<typename U > | |
bool | waitDequeTimed (U &result, std::int64_t timeout_usecs) |
template<typename U > | |
void | waitDequeue (U &result) |
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 691 of file readerwriterqueue.h.
|
private |
Definition at line 694 of file readerwriterqueue.h.
|
inlineexplicit |
Definition at line 697 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 849 of file readerwriterqueue.h.
|
inline |
Definition at line 730 of file readerwriterqueue.h.
|
inline |
Definition at line 743 of file readerwriterqueue.h.
|
inlineprivate |
Definition at line 852 of file readerwriterqueue.h.
|
inline |
Definition at line 820 of file readerwriterqueue.h.
|
inline |
Definition at line 828 of file readerwriterqueue.h.
|
inline |
Definition at line 842 of file readerwriterqueue.h.
|
inline |
Definition at line 757 of file readerwriterqueue.h.
|
inline |
Definition at line 704 of file readerwriterqueue.h.
|
inline |
Definition at line 717 of file readerwriterqueue.h.
|
inline |
Definition at line 788 of file readerwriterqueue.h.
|
inline |
Definition at line 772 of file readerwriterqueue.h.
|
private |
Definition at line 857 of file readerwriterqueue.h.
|
private |
Definition at line 858 of file readerwriterqueue.h.