core.clj

(defmacro <!?
  "Exception-aware parking take. If a Throwable is returned
  from the channel, it is re-thrown."
  [c]
  `(let [v# (<! ~c)]
     (if (instance? Throwable v#)
       (throw v#)
       v#)))

(defmacro <!!?
  "Exception-aware blocking take. If a Throwable is returned
  from the channel, it is rethrown."
  [c]
  `(let [v# (<!! ~c)]
     (if (instance? Throwable v#)
       (throw v#)
       v#)))

(defmacro go-try
  "Tries to execute the body in a go block. If an exception is thrown,
  it is placed on the channel."
  [& body]
  `(go
     (try
       ~@body
       (catch Throwable t#
         t#))))

(defmacro thread-try
  "Tries to execute the body in a thread block. If an exception is thrown,
  it is placed on the channel."
  [& body]
  `(thread
     (try
       ~@body
       (catch Throwable t#
         t#))))