scheduling a function via concurrent Executors

schedule_at_fixed_rate.clj

(import '(java.util.concurrent Executors TimeUnit))

(defn schedule-at-fixed-rate [se f init-delay period]
  (.scheduleAtFixedRate
    se
    (fn [] (try (f) (catch Throwable e (.printStackTrace e))))
    init-delay period
    TimeUnit/SECONDS))

(defn cancel [se]
  (.cancel se true))

(def s (Executors/newSingleThreadScheduledExecutor))

(def r (schedule-at-fixed-rate s #(prn "HI!") 5 5))

;; wait...
(Thread/sleep 10000)

(cancel r)