—— Concurrent Priority Queue Implementation ——
bool processOption(StringPiece name, StringPiece value)
uint64_t value(const typename LockFreeRingBuffer< T, Atom >::Cursor &rbcursor)
std::shared_ptr< LogWriter > createWriter(File file)
Optional< size_t > maxBufferSize_