Clojure delay benchmark

test-delay.clj

(ns test-delay
  (:import [java.util.concurrent CyclicBarrier]))

(defn benchmark-delay [threads]
  (let [n (rand-int 100)
        d (delay (inc n))
        ret (inc n)
        ^CyclicBarrier barrier (CyclicBarrier. (+ threads 1))]
    (dotimes [_ threads]
      (->
       (Thread.
        (fn []
          (.await barrier)
          (dotimes [_ 10000]
            (when-not (= @d ret)
              (println "deref error")))
          (.await barrier)))
       (.start)))
    (.await barrier)
    (.await barrier)
    (println "ret:" ret "@d:" @d)))