在clojure同步计数器

Question

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

Answer 1

我会用Clojure中的原子做到这一点:

(def counter (atom 0N))

;; increment the counter
(swap! counter inc)

;; read the counter
@counter
=> 1

这完全是线程安全的,并且具有令人惊讶的高性能.此外,因为它使用Clojure的abitrary-precision数字处理,所以它不易受整数溢出的影响,因为volatile可以是......

Answer 2

将全局计数器定义为 agent

(def counter (agent 0))

要将代理中包含的值增加到代理程序send(在本例中inc),

(send counter inc)

要读取您可以使用的当前值deref或@读取器宏:

@counter ;; same as (deref counter)

代理只是几种可用引用类型中的一种.您可以在Clojure网站上阅读有关这些内容的更多信息:

• 高级概述
• 软件事务内存与引用
• 异步代理
• 原子