(import '(java.util.concurrent LinkedBlockingQueue TimeUnit))

(def q (LinkedBlockingQueue. 5))

(future (while true
          (println (str "took " (.take q)))
          (Thread/sleep 500))) ; simulate slow IO

(doseq [x (range 10)]
  (println (str "offering " x))
  (.offer q x 100 TimeUnit/SECONDS))