优雅地退出 Clojure core.async go loop on kill

Question

我有一个顶级的 core.async 循环。我希望它无限期地运行，至少在我用 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")))

这是我的问题：

1. 如果我启动 REPL 和 (run)，它就会启动并在后台线程中运行。当我退出 REPL 时，我没有看到所需的关闭消息。

2. 但是，当我从lein run 运行时，go 循环立即退出并显示“SHUTDOWN”。

两者都不是我想要的。

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

• Mac JVM：java 版本“1.7.0_45”Java(TM) SE 运行时环境（内部版本 1.7.0_45-b18）Java HotSpot(TM) 64 位服务器 VM（内部版本 24.45-b08，混合模式）

• Ubuntu JVM：java 版本“1.7.0_25”OpenJDK 运行时环境 (IcedTea 2.3.10) (7u25-2.3.10-1ubuntu0.12.04.2) OpenJDK 64 位服务器 VM（内部版本 23.7-b01，混合模式）

Answer 1

您可以使用信号exit-ch 并执行条件以查看是否应该退出循环。 alt! 在 clojure 中更好地处理通道 + 条件：

(ns async-demo.core
  (:require [clojure.core.async :refer [chan go-loop alt! timeout put!]]))

(defn run
  []
  (let [exit-ch (chan)]
    (go-loop []
      (alt!
         (timeout 10) (recur)
         exit-ch nil
    exit-ch

(let [exit-ch (run)]
  (.addShutdownHook (Runtime/getRuntime) (put! exit-ch true)))

如果您只是 close! 频道，它不会停止循环运行。另外，don't need to start a go block just to send a value to a channel。

Answer 2

关于第 1 部分：“当我退出 REPL 时，我没有看到所需的关闭消息。”我认为关闭线程没有连接到lein repl 的控制台。

关于第2部分：go循环启动后，它在后台线程中运行。由于创建 go 块后主线程退出，因此程序关闭。要使循环长寿命，需要将其放入普通的loop。 （在里面放一个Thread/sleep 也更好！）

Answer 3

go 函数返回一个频道。你可能想在关机钩子中(close! chan)。

如果你运行 lein run，你需要一个 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)))