gistfile1.clj

(ns messagepassing.core)

(import [java.util.concurrent LinkedTransferQueue])
(def m 10000000)

(defn queue-test []
  (defn bounce [in out m]
    (let [value (.take in)]
      (if (< value m)
        (do
          (.put out (inc value))
          (recur in out m))
        value)))

  (time
    (let [q1 (LinkedTransferQueue. [1])
          q2 (LinkedTransferQueue.)
          w1 (future (bounce q1 q2 m))
          w2 (future (bounce q2 q1 m))]
      (prn @w2)
      (future-cancel w1))))

(defn atom-test []
  (defn bump [a m]
    (when (> m (swap! a (fn [value]
                          (if (< value m)
                            (inc value)
                            value))))
      (recur a m)))

  (time
    (let [x (atom 1)
          w1 (future (bump x m))
          w2 (future (bump x m))]
      @w1
      @w2
      (prn @x))))

(defn -main
  "I don't do a whole lot."
  [test & args]
  (case test
    "queue" (queue-test)
    "atom" (atom-test))
  (shutdown-agents))