下面列出了java.util.concurrent.atomic.DoubleAdder#add() 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
/**
* intValue returns current value.
*/
public void testIntValue() {
DoubleAdder ai = new DoubleAdder();
assertEquals(0, ai.intValue());
ai.add(1.0);
assertEquals(1, ai.intValue());
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
/**
* toString returns current value.
*/
public void testToString() {
DoubleAdder ai = new DoubleAdder();
assertEquals(Double.toString(0.0), ai.toString());
ai.add(1.0);
assertEquals(Double.toString(1.0), ai.toString());
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
static void testDoubleAdder() {
DoubleAdder a = new DoubleAdder();
a.add(20.1d);
DoubleAdder result = echo(a);
if (result.doubleValue() != a.doubleValue())
throw new RuntimeException("Unexpected doubleValue");
checkSerialClassName(a, "java.util.concurrent.atomic.DoubleAdder$SerializationProxy");
}
/**
* add adds given value to current, and sum returns current value
*/
public void testAddAndSum() {
DoubleAdder ai = new DoubleAdder();
ai.add(2.0);
assertEquals(2.0, ai.sum());
ai.add(-4.0);
assertEquals(-2.0, ai.sum());
}
/**
* reset() causes subsequent sum() to return zero
*/
public void testReset() {
DoubleAdder ai = new DoubleAdder();
ai.add(2.0);
assertEquals(2.0, ai.sum());
ai.reset();
assertEquals(0.0, ai.sum());
}
/**
* sumThenReset() returns sum; subsequent sum() returns zero
*/
public void testSumThenReset() {
DoubleAdder ai = new DoubleAdder();
ai.add(2.0);
assertEquals(2.0, ai.sum());
assertEquals(2.0, ai.sumThenReset());
assertEquals(0.0, ai.sum());
}
/**
* add adds given value to current, and sum returns current value
*/
public void testAddAndSum() {
DoubleAdder ai = new DoubleAdder();
ai.add(2.0);
assertEquals(2.0, ai.sum());
ai.add(-4.0);
assertEquals(-2.0, ai.sum());
}
public void run() {
phaser.arriveAndAwaitAdvance();
phaser.arriveAndAwaitAdvance();
DoubleAdder a = adder;
for (int i = 0; i < incs; ++i)
a.add(1.0);
result = a.sum();
phaser.arrive();
}
/**
* doubleValue returns current value.
*/
public void testDoubleValue() {
DoubleAdder ai = new DoubleAdder();
assertEquals(0.0, ai.doubleValue());
ai.add(1.0);
assertEquals(1.0, ai.doubleValue());
}