NewBoundedQueue constructs the new queue of specified capacity, and with an optional callback for dropped items (e.g.

BoundedQueue implements a producer-consumer exchange similar to a ring buffer queue, where the queue is bounded and if it fills up due to slow consumers, the new items written by the producer force the earliest items to be dropped.

Consumer consumes data from a bounded queue.

ConsumerFunc is an adapter to allow the use of a consume function callback as a Consumer.