Benchmark for functional-core-async

functional-core-async-bench.clj

(defn event [env type val]
  (let [rc (chan)]
    (>! (:queue @env)
        {:type type :val val :rc rc :time (:now @env)})
    (<! rc)))


(defn bench []
  (time
   (let [n 100000
         env (atom {:now 0 :queue (chan)})]
     ;; car
     (go
       (loop []
         #_(println "Driving at " (:now @env))
         (event env :timeout 5)
         #_(println "Parking at " (:now @env))
         (event env :timeout 2)
         (when (< (:now @env) n)
           (recur)))) 
     (loop []
       (let [e (<! (:queue @env))
             nt (+ (:val e) (:now @env))]
         (when (< nt n)
           (swap! env assoc :now nt)
           (go (>! (:rc e) true))
           (recur)))))))

A port of this core.async example.
Taken from the mailing list (posted by user kandre).
Takes 0.5s on my machine.