--- jsr166/src/test/tck/AtomicLongArrayTest.java 2003/09/07 20:39:11 1.2 +++ jsr166/src/test/tck/AtomicLongArrayTest.java 2003/09/20 18:20:07 1.4 @@ -9,10 +9,7 @@ import junit.framework.*; import java.util.concurrent.atomic.*; import java.io.*; -public class AtomicLongArrayTest extends TestCase -{ - static final int N = 10; - +public class AtomicLongArrayTest extends JSR166TestCase { public static void main (String[] args) { junit.textui.TestRunner.run (suite()); } @@ -20,15 +17,21 @@ public class AtomicLongArrayTest extends return new TestSuite(AtomicLongArrayTest.class); } + /** + * + */ public void testConstructor(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) assertEquals(0,ai.get(i)); } + /** + * + */ public void testGetSet(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(1,ai.get(i)); ai.set(i, 2); @@ -38,9 +41,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testCompareAndSet(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertTrue(ai.compareAndSet(i, 1,2)); assertTrue(ai.compareAndSet(i, 2,-4)); @@ -52,9 +58,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testWeakCompareAndSet(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); while(!ai.weakCompareAndSet(i, 1,2)); while(!ai.weakCompareAndSet(i, 2,-4)); @@ -64,9 +73,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testGetAndSet(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(1,ai.getAndSet(i,0)); assertEquals(0,ai.getAndSet(i,-10)); @@ -74,9 +86,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testGetAndAdd(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(1,ai.getAndAdd(i,2)); assertEquals(3,ai.get(i)); @@ -85,9 +100,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testGetAndDecrement(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(1,ai.getAndDecrement(i)); assertEquals(0,ai.getAndDecrement(i)); @@ -95,9 +113,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testGetAndIncrement(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(1,ai.getAndIncrement(i)); assertEquals(2,ai.get(i)); @@ -109,9 +130,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testAddAndGet() { - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(3,ai.addAndGet(i,2)); assertEquals(3,ai.get(i)); @@ -120,9 +144,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testDecrementAndGet(){ - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(0,ai.decrementAndGet(i)); assertEquals(-1,ai.decrementAndGet(i)); @@ -131,9 +158,12 @@ public class AtomicLongArrayTest extends } } + /** + * + */ public void testIncrementAndGet() { - AtomicLongArray ai = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) { + AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) { ai.set(i, 1); assertEquals(2,ai.incrementAndGet(i)); assertEquals(2,ai.get(i)); @@ -145,9 +175,59 @@ public class AtomicLongArrayTest extends } } + static final long COUNTDOWN = 100000; + + class Counter implements Runnable { + final AtomicLongArray ai; + volatile long counts; + Counter(AtomicLongArray a) { ai = a; } + public void run() { + for (;;) { + boolean done = true; + for (int i = 0; i < ai.length(); ++i) { + long v = ai.get(i); + threadAssertTrue(v >= 0); + if (v != 0) { + done = false; + if (ai.compareAndSet(i, v, v-1)) + ++counts; + } + } + if (done) + break; + } + } + } + + /** + * + */ + public void testCountingInMultipleThreads() { + try { + final AtomicLongArray ai = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) + ai.set(i, COUNTDOWN); + Counter c1 = new Counter(ai); + Counter c2 = new Counter(ai); + Thread t1 = new Thread(c1); + Thread t2 = new Thread(c2); + t1.start(); + t2.start(); + t1.join(); + t2.join(); + assertEquals(c1.counts+c2.counts, SIZE * COUNTDOWN); + } + catch(InterruptedException ie) { + unexpectedException(); + } + } + + /** + * + */ public void testSerialization() { - AtomicLongArray l = new AtomicLongArray(N); - for (int i = 0; i < N; ++i) + AtomicLongArray l = new AtomicLongArray(SIZE); + for (int i = 0; i < SIZE; ++i) l.set(i, -i); try { @@ -159,12 +239,11 @@ public class AtomicLongArrayTest extends ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray()); ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin)); AtomicLongArray r = (AtomicLongArray) in.readObject(); - for (int i = 0; i < N; ++i) { + for (int i = 0; i < SIZE; ++i) { assertEquals(l.get(i), r.get(i)); } } catch(Exception e){ - e.printStackTrace(); - fail("unexpected exception"); + unexpectedException(); } }