Clojure中的同步计数器

Question

如果我想保留一个全局计数器（例如，计算多个线程中传入请求的数量），那么在 java 中最好的方法是使用 volatile int。假设正在使用 clojure，是否有更好的（更好的吞吐量）方法？

Answer 1

我会使用 Clojure 中的 atom 来完成此操作：

(def counter (atom 0N))

;; increment the counter
(swap! counter inc)

;; read the counter
@counter
=> 1

这是完全线程安全的，并且性能令人惊讶。此外，由于它使用 Clojure 的任意精度数字处理，因此它不会像易失性 int 那样容易受到整数溢出的影响......

Answer 2

将全局计数器定义为 代理

(def counter (agent 0))

要增加代理中包含的值，您发送< /a> 一个函数（在本例中 inc) 到代理：

(send counter inc)

读取当前值，您可以使用 deref 或@ 阅读器宏：

@counter ;; same as (deref counter)

代理只是几种可用的参考类型之一。您可以在 Clojure 网站上阅读有关这些内容的更多信息：

• 高级概述
• 带有参考的软件事务内存
• 异步代理
• Atoms