Clojure：阻止使用原子？

Question

我有一個並行運行幾個線程的Clojure代碼。它們都共享一個原子：(def counter (atom 0))，它由每個線程遞增。每10分鐘後，我想執行使用原子值幾個動作，然後重置回0 - 例如：

(defn publish-val [] 
    (let [c @counter] 
    (email c) 
    (statsd c) 
    (print-log c) 
    (reset! counter 0))) 

說的counter值將不會從此刻改變是很重要的它被解除引用到它被重置的那一刻 - 這意味着在嘗試更改原子值時所有線程都應該被阻塞，而執行publish-val。我該怎麼做呢？

Answer 1

除非你已經大大簡化了你的榜樣的問題，它看起來像swap! -ing出與零電流計數器的值就足夠了這裏：

(defn publish-val [] 
    (with-local-vars [c nil] 
    (swap! counter 
      (fn [x] (var-set c x) 0)) 
     (email @c) 
     (statsd @c) 
     (print-log @c))) 

所以，你只需保存你的舊計數器值在一個局部變量，零原子交換，然後做舊做任何簿記需要的價值都沒有拖延任何其他線程長的比它採取到swap!

Answer 2

使用代理。

請參閱部分Using agents to serialise access to non-threadsafe resources用它們打印到控制檯