                          ct))
                      (partition-work n threads)))]
        (.await latch)
-       (reduce #(+ %1 (deref %2)) 0 res))))+       (reduce #(+ %1 (deref %2)) 0 res))))

    s*))

(defn log [& s]
  (send-off *logger* log* s))

(defn partition-work
  "Break up total number of messages evenly over desired number of threads."


(def DATEFORMAT (SimpleDateFormat. "yyyy-MM-dd.HH:mm:ss"))

(defonce counter (atom 0))

(defn reset-counter! []
  (reset! counter 0))

(def logger (agent nil))

(defn log* [x s]
  (let [s* (format "%s %s"
