在性能测试中,其本质基础就是多线程编程。这其中多线程安全计数是一个很常见的使用场景,在此之前我用的是java.util.concurrent.atomic.AtomicLong
或者java.util.concurrent.atomic.AtomicInteger
,但是在最近深入学习多线程编程的过程中(随着线程数增加),发现知识又需要增加了。
随着java.util.concurrent.atomic.LongAdder
来到视野中,下面分享一下基础使用和性能测试。
LongAdder
中会维护一组变量,这些变量加起来就是要以原子方式更新的long
型变量。当更新方法add(long)
在线程间竞争时,该组变量可以动态增长以减缓竞争。方法sum()
返回当前在维持总和的变量上的总和。与AtomicLong
相比,在低并发环境下,两者性能很相似。但在高并发环境下,LongAdder
有着明显更高的吞吐量,但是有着更高的空间复杂度(就是内存占用偏高)。LongAdder
是JDK1.8
开始出现的,所提供的API
基本上可以替换掉原先的AtomicLong
。
对于计数器功能来讲,常用的功能无法三种:构造方法、计数方法(增减)、统计方法(获取值)。
java.util.concurrent.atomic.LongAdder
只有一个构造方法:
/**
* Creates a new adder with initial sum of zero.
*/
public LongAdder() {
}
默认值0
。
这里java.util.concurrent.atomic.LongAdder
提供的四种:增减 1,增减任意值。都比较简单。简单看一下源码即可上手。这里分享一个重置方法。
/**
* Resets variables maintaining the sum to zero. This method may
* be a useful alternative to creating a new adder, but is only
* effective if there are no concurrent updates. Because this
* method is intrinsically racy, it should only be used when it is
* known that no threads are concurrently updating.
*/
public void reset() {
Cell[] as = cells; Cell a;
base = 0L;
if (as != null) {
for (int i = 0; i < as.length; ++i) {
if ((a = as[i]) != null)
a.value = 0L;
}
}
}
由于设计思路和运行机制,这个reset()
并不常用,如果是到达某个值就reset()
重新计数,大多数情况下并不能符合预期。包括后面还有一个java.util.concurrent.atomic.LongAdder#sumThenReset
方法也是一样的,不过可以做一个定时获取存量重新计数的功能,说白点,就是 QPS 取样器。
统计方法中最核心的是java.util.concurrent.atomic.LongAdder#sum
,其他java.util.concurrent.atomic.LongAdder#intValue
或者java.util.concurrent.atomic.LongAdder#longValue
都是基于此方法。然后把值转成其他类型返回。
/**
* Returns the current sum. The returned value is <em>NOT</em> an
* atomic snapshot; invocation in the absence of concurrent
* updates returns an accurate result, but concurrent updates that
* occur while the sum is being calculated might not be
* incorporated.
*
* @return the sum
*/
public long sum() {
Cell[] as = cells; Cell a;
long sum = base;
if (as != null) {
for (int i = 0; i < as.length; ++i) {
if ((a = as[i]) != null)
sum += a.value;
}
}
return sum;
}
同样的道理,这个方法在性能测试中,自然也不是那么实时。这个问题需要避免。
下面写个简单的性能测试脚本:
public static void main(String[] args) {
LongAdder adder = new LongAdder()
POOL_SIZE = 1000
def phaser = new Phaser(1)
time {
POOL_SIZE.times {
fun {
1000000.times {
adder.increment()
}
} , phaser
}
phaser.arriveAndAwaitAdvance()
}
output(formatLong(adder.longValue()))
}
我的测试方案是固定 1000 个线程,调整单线程次数。下面是测试结果:
INFO-> 34.738 main 执行1次耗时:11,088 ms
INFO-> 34.739 main 1,000,000,000
INFO-> 19.588 main 执行1次耗时:1,194 ms
INFO-> 19.588 main 100,000,000
INFO-> 07.095 main 执行1次耗时:441 ms
INFO-> 07.096 main 10,000,000
下面是java.util.concurrent.atomic.AtomicLong
的测试结果:
INFO-> 29.627 main 执行1次耗时:30,570 ms
INFO-> 29.628 main 1,000,000,000
INFO-> 45.557 main 执行1次耗时:4,600 ms
INFO-> 45.558 main 100,000,000
INFO-> 22.594 main 执行1次耗时:633 ms
INFO-> 22.595 main 10,000,000
对比之下,果断换了。PS:LongAdder
只有在竞争比较多的时候性能比AtomicLong
性能好很多。除此以外,还是老老实实用旧的。