Producer Consumer Queue in Clojure

Question

I want to build a producer-consumer program in clojure. The requirement is the consumer can drag items from the queue while the producer is putting messages into the queue, if using java I will use ConcurrentLinkedQueue, but I'm not very sure how to do it in clojure using the immutable collections, please help.

Do you know about [clojure.lang.PersistentQueue](https://github.com/clojure/clojure/blob/master/src/jvm/clojure/lang/PersistentQueue.java)? — Jeremy, Jul 28 '12 at 17:14
@JeremyHeiler I'd expect to use pure clojure code like vector, list, ref kind of things to implement this, just dont know if it is possible? — James.Xu, Jul 28 '12 at 17:17

score 3 · Answer 1 · edited May 23 '17 at 10:24

3

If you just want 1 consumer, just use an agent. If not see see Clojure Producer Consumer or Producer consumer with qualifications

edited May 23 '17 at 10:24

Community

1
1

answered Jul 28 '12 at 22:05

DanLebrero

8,545
1
29
30

Alex Baranosky · Answer 2 · 2012-07-28T17:52:43.917

2

I think you could use Clojure's immutable queue inside of an atom, which would give you atomic access to the queue.

edited Jul 28 '12 at 17:52

answered Jul 28 '12 at 17:27

Alex Baranosky

48,865
44
102
150

Producer Consumer Queue in Clojure

2 Answers2