returns the timeunit

(q/->timeunit :ms) => java.util.concurrent.TimeUnit/MILLISECONDS

constructs a blocking deque

(q/deque 1 2 3) => java.util.concurrent.LinkedBlockingDeque

checks if object is a BlockingDeque

drains elements to another vector

((juxt #(q/drain % 2) #(into [] %)) (q/queue 1 2 3 4)) => [1 2 3 4]

takes element at the front of the queue

(q/peek (q/queue))

peeks from the front of the queue

peeks from the back of the queue

pops from the front of the queue

processes elements in the queue

(def +state+ (atom []))

(q/process-bulk (fn elems(swap! +state+ conj elems)) (q/queue 1 2 3 4 5) 3)

@+state+ => [1 2 3 4 5]

puts at the front of the queue

puts an element at the back

(->> (doto (q/queue) (q/put 1)) (into [])) => 1

puts at the front of the queue

puts at the back of the queue

constructs a blocking queue

(q/queue 1 2 3) => java.util.concurrent.LinkedBlockingQueue

constructs a fixed size blocking queue

(type (q/queue:fixed 10)) => java.util.concurrent.ArrayBlockingQueue

constructs a limited queue

(q/queue:limited 10)

checks if object is a BlockingQueue

returns the remaining capacity

(q/remaining-capacity (q/queue)) => 2147483647

(q/remaining-capacity (doto (q/queue:fixed 2) (q/put 1))) => 1

removes element from queue

takes an element from the queue

((juxt q/take #(into [] %)) (q/queue 1 2 3)) => [1 2 3]

takes from the front of the queue

takes from the back of the queue