Concurrency test

gistfile1.clj

(require '[clojure.tools.logging :as log])
(import '(java.util.concurrent Executors))
(defn t [f expected nthreads niters]
  (let [pool  (Executors/newFixedThreadPool nthreads)
        tasks (map (fn [t]
                      (fn []
                        (dotimes [n niters]
                          (let [res (f)]
                            (when (not= res expected)
                              (log/info "Result is not expected : " res))))))
                   (range nthreads))]
    (doseq [future (.invokeAll pool tasks)]
      (.get future))))