Clojure: Blockieren Sie die Verwendung eines Atoms?

Question

Ich habe einen Clojure-Code, der ein paar Threads parallel läuft. Sie teilen sich alle ein Atom: (def counter (atom 0)), das von jedem Thread inkrementiert wird. Jede 10 Minuten, würde Ich mag verschiedene Aktionen mit dem Wert des Atoms führen und es dann auf 0 zurückgesetzt - zum Beispiel:

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

Es ist wichtig, dass der Wert von counter nicht von dem Moment ändern Es ist dereferenziert auf den Moment, wenn es zurückgesetzt wird - was bedeutet, dass alle Threads blockiert werden sollten, wenn versucht wird, den Wert des Atoms zu ändern, während publish-val ausgeführt wird. Wie mache ich das?

Answer 1

zu trösten zu drucken, wenn Sie stark das Problem für Ihr Beispiel vereinfacht haben, sieht es aus wie swap! mit Null den aktuellen Zählerwert -ing würde hier ausreichend sein:

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

So sparen Sie nur Ihren alten Zählerwert in einer lokalen variablen, tauschen sie atomar mit Null, und dann tun, was Buchhaltung mit der alten zu tun, benötigen wert alles ohne länger keines der anderen Fäden Abwürgen als es dauert, zu swap!

Answer 2

Verwenden Sie einen Agenten.

Siehe Abschnitt Using agents to serialise access to non-threadsafe resources über die Verwendung von ihnen