Rob Nikander <rob.nikan...@gmail.com> writes: > Thanks for the explanation! This is very close to what I want. I see some > confusing behavior though. See below. > > On Friday, January 5, 2018 at 2:40:14 PM UTC-5, Brian J. Rubinton wrote: >> >> >> The work-queue channel has a fixed buffer size of 1. A collection (range >> 50) is put on the channel. While consumers can take items off the channel — >> note the individual contents of (range 50) are returned — a producer cannot >> put another value onto the channel until the entire initial collection is >> consumed. >> > > I tried your example code works for me, but then I tried using `>!!` > instead of `offer!` and it behaves differently. > > user> (def c (chan 1 (mapcat identity))) > => #'user/c > user> (do > (async/thread (async/>!! c [1 2 3]) (println "put #1")) > (async/thread (async/>!! c [4 5 6]) (println "put #2")) > (async/thread (async/>!! c [7 8 9]) (println "put #3"))) > put #1 > > As expected it prints "put #1" right away, and other threads are blocked. > But... > > user> (poll! c) > => 1 > put #2 > user> (poll! c) > => 2 > put #3 > > As soon as your read anything from it, other puts succeed. Shouldn't they > be blocked?
You have a channel with a buffer-size of one. You clear the buffer by taking one item from it, making room for another one. Therefore the put succeeds. Try just `(async/chan nil xform)` to create a channel without a backing buffer (a rendezvouz channel) where puts only succeed if there's a matching consumer. -- You received this message because you are subscribed to the Google Groups "Clojure" group. To post to this group, send email to clojure@googlegroups.com Note that posts from new members are moderated - please be patient with your first post. To unsubscribe from this group, send email to clojure+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/clojure?hl=en --- You received this message because you are subscribed to the Google Groups "Clojure" group. To unsubscribe from this group and stop receiving emails from it, send an email to clojure+unsubscr...@googlegroups.com. For more options, visit https://groups.google.com/d/optout.
