Class faabric::util::Queue

template<typename T> class Queue

Public Functions

inline void enqueue(T value)

inline void dequeueIfPresent(T *res)

inline T dequeue(long timeoutMs = DEFAULT_QUEUE_TIMEOUT_MS)

inline T *peek(long timeoutMs = 0)

inline void waitToDrain(long timeoutMs)

inline void drain()

inline long size()

inline void reset()