创建一个在心跳上运行的 clojurescript atom

Question

(ns example.asyncq
  (:require
   [cljs.core.async :as async]
   goog.async.AnimationDelay)
  (:require-macros
   [cljs.core.async.macros :refer [go go-loop]]))

(defn loop-fx-on-atm-when-pred?-is-true [atm fx pred?]
  (let [c (async/chan)
        f (goog.async.AnimationDelay. #(async/put! c :loop))
        a (atom false)]
    (add-watch 
     atm
     :loop-fx-on-atm-when-pred?-is-true
     (fn [_ _ _ _]
       (when-not @a
         (async/put! c :initial-loop))))
    (go-loop []
      (async/<! c)
      (reset! a true)
      (swap! atm #(if (pred? %) (do (.start f) (fx %)) %))
      (reset! a false)
      (recur))))

(def the-final-countdown (atom 4))

(loop-fx-on-atm-when-pred?-is-true
 the-final-countdown
 #(do (js/console.log %) (dec %))
 pos?)

(swap! the-final-countdown inc)
;; prints "5" "4" "3" "2" "1", each on a seperate frame (hearbeat)

loop-fx-on.... 的目的是注册fx，以便在pred? @atm 为true 时在atm（每次心跳）上调用。

我想要以下属性：

1. 仅当pred? 可能返回true 时才应执行此代码。否则，状态机将处于空闲状态。
2. 这不应该每帧注册一次以上。在调用 AnimationDelay 之后但在下一个实际帧之前对原子的修改实际上是 noops。即修改了原子，但不会导致再次调用f。
3. 从使用原子的人的角度来看，他们需要做的就是修改原子。他们不需要关心为 AnimationFrame 处理注册或取消注册原子，它只是工作。原子将继续每帧处理，直到pred? 返回 false。

我对上述代码最大的不满是 (reset! a true) 和 (reset! a false) 在 swap! 周围。这真的很难看，在非单线程环境中可能是一个错误。有什么方法可以改进这段代码，这样我就不会使用a 了吗？

我的第二个担心是没有满足 2。目前，如果你在一帧之间修改同一个原子两次，它实际上会导致对 (f) 的 2 次调用；或下一帧的 2 个回调。我可以使用另一个原子来记录我是否真的注册了这个框架，但这已经变得很乱了。有更好的吗？

Answer 1

这样的事情可能对你有用：

(defn my-fn [a f pred]
  (let [pending? (atom false)
        f (fn []
            (reset! pending? false)
            (f @a))]
    (add-watch a (gensym)
      (fn [_k _a _old-val new-val]
        (when (and (not @pending?) (pred new-val))
          (reset! pending? true)
          (if (exists? js/requestAnimationFrame)
            (js/requestAnimationFrame f)
            (js/setTimeout f 16)))))))