interrupted.clj

(ns onyx.metrics.riemann-playground)

(require '[riemann.client :as r])

(def c (r/tcp-client {:host "192.168.99.100" :port 35002}))

(defn intensive-computation []
  (let [prom (r/send-events c (repeat 100000 {:status "ok"}))]
    (println "Obtained promise")
    (println (deref prom 5000 ::timeout5000))))

(def f (future
         (try
           (while (not (Thread/interrupted))
             (println (Thread/interrupted))
             (println "ready to go")
             (println (intensive-computation)))
           (catch Exception e 
             (println e)
             (.interrupt (Thread/currentThread))
             (throw (RuntimeException. e)))
           (finally (println "finally")))))
(Thread/sleep 10000)
(future-cancel f)