优雅地退出Clojure Core.Async go循环在kill

Question

我有一个顶级核心.异步运行循环。我想让它无限期地运行，至少直到我用CTRL-C或kill或类似的方式示意它停止。我当前正在使用java.lang.runtime/AddShutDownHook，如下所示：

(ns async-demo.core
  (:require [clojure.core.async :as async
             :refer [<! >! <!! timeout chan alt! go]]))
(defn run [] (go (loop [] (recur))))
(.addShutdownHook (Runtime/getRuntime) (Thread. #(println "SHUTDOWN")))

我想要的也不是。

我不一定期望找到一个适用于所有JVM的解决方案。我在Mac上开发并部署到Ubuntu上，所以我想找到一个同时适用于两者的解决方案：

>

Mac JVM：java版本“1.7.0_45”java(TM)SE运行时环境（build 1.7.0_45-B18)java HotSpot(TM)64位服务器VM（build 24.45-B08，混合模式）

Answer 1

go函数返回一个通道。您可能希望在shutdown挂钩中使用（关闭！chan)。

如果在run中运行le，则需要一个main函数，该函数将调用(run)来启动go线程。

(ns async-demo.core
  (:require [clojure.core.async :as async
             :refer [<! >! <!! timeout chan alt! go close!]]))

(def ch (atom nil))

(defn run []
  (go (while true
        (<! (timeout 500))
        (prn "inside go"))))

(defn -main [& args]
  (println "Starting")
  (reset! ch (run))
  (.addShutdownHook (Runtime/getRuntime)
                    (Thread. #(do
                                (println "SHUTDOWN")
                                (close! @ch))))
  (while true
    (<!! @ch)))