co.multiply.conc.queue — co.multiply/conc 0.1.1

A concurrent queue backed by a lock-free Deque.

Values are wrapped in ValueLink internally, hiding the link machinery. Null values are not permitted (poll returns nil to indicate empty).

Thread-safe for concurrent add/poll operations on JVM. Single-threaded on ClojureScript (backed by Deque).

add clj/s macro

(add queue item)

Add a value to the tail of the queue.

Returns a Link that can be used for O(1) removal via (queue/remove link).

forEach clj/s macro

(forEach [sym queue] & body)

Iterate over all values in the queue.

isEmpty clj/s macro

(isEmpty queue)

Check if the queue is empty.

iterator clj/s macro

(iterator queue)

Get an iterator over the queue values.

iteratorHasNext clj/s macro

(iteratorHasNext it)

Check if the iterator has more elements.

iteratorNext clj/s macro

(iteratorNext it)

Get the next value from the iterator.

poll clj/s macro

(poll queue)

Remove and return the first value from the queue, or nil if empty.

queue clj/s macro

(queue)

Create a new concurrent queue.

remove clj/s macro

(remove link)

Remove a link from its queue.

Returns true if this call initiated the removal, false if already removed.

size clj/s macro

(size queue)

Get the number of values in the queue.