ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/LongAccumulatorTest.java

Comparing jsr166/src/test/tck/LongAccumulatorTest.java (file contents):
Revision 1.1 by dl, Wed Mar 20 20:29:02 2013 UTC vs.
Revision 1.2 by dl, Thu Mar 21 00:26:43 2013 UTC

#	Line 119 | Line 119 | public class LongAccumulatorTest extends
119		LongAccumulator a = new LongAccumulator(Long::max, 0L);
120		Phaser phaser = new Phaser(nthreads + 1);
121		for (int i = 0; i < nthreads; ++i)
122	<	pool.execute(new AccumulateerTask(a, phaser, incs));
122	>	pool.execute(new AccTask(a, phaser, incs));
123		phaser.arriveAndAwaitAdvance();
124		phaser.arriveAndAwaitAdvance();
125		long expected = incs - 1;
#	Line 128 | Line 128 | public class LongAccumulatorTest extends
128		pool.shutdown();
129		}
130
131	<	static final class AccumulateerTask implements Runnable {
132	<	final LongAccumulator accumulateer;
131	>	static final class AccTask implements Runnable {
132	>	final LongAccumulator acc;
133		final Phaser phaser;
134		final int incs;
135		volatile long result;
136	<	AccumulateerTask(LongAccumulator accumulateer, Phaser phaser, int incs) {
137	<	this.accumulateer = accumulateer;
136	>	AccTask(LongAccumulator acc, Phaser phaser, int incs) {
137	>	this.acc = acc;
138		this.phaser = phaser;
139		this.incs = incs;
140		}
141
142		public void run() {
143		phaser.arriveAndAwaitAdvance();
144	<	LongAccumulator a = accumulateer;
144	>	LongAccumulator a = acc;
145		for (int i = 0; i < incs; ++i)
146		a.accumulate(i);
147		result = a.get();

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines