Class faabric::util::FixedCapacityQueue

template<typename T> class FixedCapacityQueue

Public Functions

inline FixedCapacityQueue(int capacity)

inline FixedCapacityQueue()

inline void enqueue(T value, long timeoutMs = DEFAULT_QUEUE_TIMEOUT_MS)

inline void dequeueIfPresent(T *res)

inline T dequeue(long timeoutMs = DEFAULT_QUEUE_TIMEOUT_MS)

inline T *peek(long timeoutMs = DEFAULT_QUEUE_TIMEOUT_MS)

inline void drain(long timeoutMs = DEFAULT_QUEUE_TIMEOUT_MS)

inline long size()

inline void reset()