Basic queuing with Lamina

gistfile1.clj

;;;  Lamina queueing
(def job-queue (lamina/channel))
(def worker-interval (atom 250))

(defn consume-jobs [] 
  (let [{:keys [c f args] :as msg} 
    @(lamina/read-channel job-queue)]
    (Thread/sleep @worker-interval)
    (lamina/enqueue c (apply f args))))

(defn job-consumer []
  (doall (repeatedly consume-jobs)))

(defn start-job-consumer []
  (-> (Thread. job-consumer) .start))

; FIXME: Enqueue needs job-consumer thread to have already been started
(defn add-to-queue [f & args] 
  (lamina/run-pipeline (lamina/channel)
    (fn [ch] 
      (lamina/enqueue job-queue {:c ch :f f :args args})
      (lamina/read-channel ch))))