我正在寻找一种在 Clojure 中定期调用函数的非常简单的方法。
JavaScript 的setInterval 有我想要的那种API。如果我在 Clojure 中重新构想它，它看起来像这样：
(def job (set-interval my-callback 1000))
; some time later...
(clear-interval job)
出于我的目的，我不介意这是否会创建一个新线程、在线程池中运行或其他什么。时间是否准确也不是关键。事实上，所提供的时间段（以毫秒为单位）可能只是一个呼叫完成结束与下一个呼叫开始之间的延迟。
【问题讨论】：
标签： clojure periodic-task
最简单的方法是在单独的线程中创建一个循环。
(defn periodically
[f interval]
(doto (Thread.
#(try
(while (not (.isInterrupted (Thread/currentThread)))
(Thread/sleep interval)
(f))
(catch InterruptedException _)))
(.start)))
您可以使用Thread.interrupt() 取消执行：
(def t (periodically #(println "Hello!") 1000))
;; prints "Hello!" every second
(.interrupt t)
您甚至可以只使用 future 来包装循环并使用 future-cancel 来停止它。
【讨论】：
^Runnable 输入提示。
Leiningen 2.6.1 on Java 1.8.0_45 Java HotSpot(TM) 64-Bit Server VM) 中尝试了它，并且在设置 *warn-on-reflection* 时它既没有产生错误也没有打印警告（因为应该只有one matching constructor)。也许 IntelliJ 捆绑了旧的 Clojure 版本？
我尝试编写此代码，界面比原始问题中指定的稍有修改。这是我想出的。
(defn periodically [fn millis]
"Calls fn every millis. Returns a function that stops the loop."
(let [p (promise)]
(future
(while
(= (deref p millis "timeout") "timeout")
(fn)))
#(deliver p "cancel")))
欢迎反馈。
【讨论】：
(ns your-namespace
(:require [clojure.core.async :as async :refer [<! timeout chan go]])
)
(def milisecs-to-wait 1000)
(defn what-you-want-to-do []
(println "working"))
(def the-condition (atom true))
(defn evaluate-condition []
@the-condition)
(defn stop-periodic-function []
(reset! the-condition false )
)
(go
(while (evaluate-condition)
(<! (timeout milisecs-to-wait))
(what-you-want-to-do)))
【讨论】：
[org.clojure/clojure "1.5.1"] [org.clojure/core.async "0.1.267.0-0d7780-alpha"]
alts! 的超时通道获取）。这将提供结束循环/期间/超时。这是我之前整理的代码示例：refheap.com/21103
另一种选择是使用 java.util.Timer 的 scheduleAtFixedRate method
编辑 - 在单个计时器上多路复用任务，并停止单个任务而不是整个计时器
(defn ->timer [] (java.util.Timer.))
(defn fixed-rate
([f per] (fixed-rate f (->timer) 0 per))
([f timer per] (fixed-rate f timer 0 per))
([f timer dlay per]
(let [tt (proxy [java.util.TimerTask] [] (run [] (f)))]
(.scheduleAtFixedRate timer tt dlay per)
#(.cancel tt))))
;; Example
(let [t (->timer)
job1 (fixed-rate #(println "A") t 1000)
job2 (fixed-rate #(println "B") t 2000)
job3 (fixed-rate #(println "C") t 3000)]
(Thread/sleep 10000)
(job3) ;; stop printing C
(Thread/sleep 10000)
(job2) ;; stop printing B
(Thread/sleep 10000)
(job1))
【讨论】：
还有很多 Clojure 的调度库： （从简单到非常高级）
直接来自at-at的github主页的例子：
(use 'overtone.at-at)
(def my-pool (mk-pool))
(let [schedule (every 1000 #(println "I am cool!") my-pool)]
(do stuff while schedule runs)
(stop schedule))
如果您希望在任务结束和下一个开始之间延迟一秒，而不是在两次开始之间，请使用 (every 1000 #(println "I am cool!") my-pool :fixed-delay true)。
【讨论】：
如果你想要很简单
(defn set-interval [callback ms]
(future (while true (do (Thread/sleep ms) (callback)))))
(def job (set-interval #(println "hello") 1000))
=>hello
hello
...
(future-cancel job)
=>true
再见。
【讨论】：
这就是我将如何使用停止通道制作 core.async 版本。
(defn set-interval
[f time-in-ms]
(let [stop (chan)]
(go-loop []
(alt!
(timeout time-in-ms) (do (<! (thread (f)))
(recur))
stop :stop))
stop))
及用法
(def job (set-interval #(println "Howdy") 2000))
; Howdy
; Howdy
(close! job)
【讨论】：