--- jsr166/src/test/tck/AtomicIntegerFieldUpdaterTest.java 2003/09/20 18:20:07 1.3 +++ jsr166/src/test/tck/AtomicIntegerFieldUpdaterTest.java 2009/11/02 20:28:31 1.10 @@ -1,8 +1,9 @@ /* - * Written by members of JCP JSR-166 Expert Group and released to the - * public domain. Use, modify, and redistribute this code in any way - * without acknowledgement. Other contributors include Andrew Wright, - * Jeffrey Hayes, Pat Fischer, Mike Judd. + * Written by Doug Lea with assistance from members of JCP JSR-166 + * Expert Group and released to the public domain, as explained at + * http://creativecommons.org/licenses/publicdomain + * Other contributors include Andrew Wright, Jeffrey Hayes, + * Pat Fisher, Mike Judd. */ import java.util.concurrent.atomic.*; @@ -11,61 +12,102 @@ import java.util.*; public class AtomicIntegerFieldUpdaterTest extends JSR166TestCase { volatile int x = 0; + int w; long z; - public static void main(String[] args){ junit.textui.TestRunner.run(suite()); } - - public static Test suite() { return new TestSuite(AtomicIntegerFieldUpdaterTest.class); } /** - * + * Construction with non-existent field throws RuntimeException */ public void testConstructor() { try{ - AtomicIntegerFieldUpdater + AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater - (getClass(), "y"); + (AtomicIntegerFieldUpdaterTest.class, "y"); shouldThrow(); } catch (RuntimeException rt) {} } /** - * + * construction with field not of given type throws RuntimeException */ public void testConstructor2() { try{ - AtomicIntegerFieldUpdater + AtomicIntegerFieldUpdater + a = AtomicIntegerFieldUpdater.newUpdater + (AtomicIntegerFieldUpdaterTest.class, "z"); + shouldThrow(); + } + catch (RuntimeException rt) {} + } + + /** + * construction with non-volatile field throws RuntimeException + */ + public void testConstructor3() { + try{ + AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater - (getClass(), "z"); + (AtomicIntegerFieldUpdaterTest.class, "w"); shouldThrow(); } catch (RuntimeException rt) {} } /** - * + * get returns the last value set or assigned */ public void testGetSet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(1,a.get(this)); a.set(this,2); assertEquals(2,a.get(this)); a.set(this,-3); assertEquals(-3,a.get(this)); - + } + /** - * + * get returns the last value lazySet by same thread + */ + public void testGetLazySet() { + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } + x = 1; + assertEquals(1,a.get(this)); + a.lazySet(this,2); + assertEquals(2,a.get(this)); + a.lazySet(this,-3); + assertEquals(-3,a.get(this)); + + } + + /** + * compareAndSet succeeds in changing value if equal to expected else fails */ public void testCompareAndSet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertTrue(a.compareAndSet(this,1,2)); assertTrue(a.compareAndSet(this,2,-4)); @@ -76,11 +118,47 @@ public class AtomicIntegerFieldUpdaterTe assertEquals(7,a.get(this)); } + /** - * + * compareAndSet in one thread enables another waiting for value + * to succeed + */ + public void testCompareAndSetInMultipleThreads() { + x = 1; + final AtomicIntegerFieldUpdatera; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } + + Thread t = new Thread(new Runnable() { + public void run() { + while(!a.compareAndSet(AtomicIntegerFieldUpdaterTest.this, 2, 3)) Thread.yield(); + }}); + try { + t.start(); + assertTrue(a.compareAndSet(this, 1, 2)); + t.join(LONG_DELAY_MS); + assertFalse(t.isAlive()); + assertEquals(a.get(this), 3); + } + catch(Exception e) { + unexpectedException(); + } + } + + /** + * repeated weakCompareAndSet succeeds in changing value when equal + * to expected */ public void testWeakCompareAndSet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; while(!a.weakCompareAndSet(this,1,2)); while(!a.weakCompareAndSet(this,2,-4)); @@ -90,10 +168,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * getAndSet returns previous value and sets to given value */ public void testGetAndSet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(1,a.getAndSet(this, 0)); assertEquals(0,a.getAndSet(this,-10)); @@ -101,10 +184,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * getAndAdd returns previous value and adds given value */ public void testGetAndAdd() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(1,a.getAndAdd(this,2)); assertEquals(3,a.get(this)); @@ -113,10 +201,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * getAndDecrement returns previous value and decrements */ public void testGetAndDecrement() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(1,a.getAndDecrement(this)); assertEquals(0,a.getAndDecrement(this)); @@ -124,10 +217,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * getAndIncrement returns previous value and increments */ public void testGetAndIncrement() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(1,a.getAndIncrement(this)); assertEquals(2,a.get(this)); @@ -139,10 +237,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * addAndGet adds given value to current, and returns current value */ public void testAddAndGet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(3,a.addAndGet(this,2)); assertEquals(3,a.get(this)); @@ -151,10 +254,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * decrementAndGet decrements and returns current value */ public void testDecrementAndGet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(0,a.decrementAndGet(this)); assertEquals(-1,a.decrementAndGet(this)); @@ -163,10 +271,15 @@ public class AtomicIntegerFieldUpdaterTe } /** - * + * incrementAndGet increments and returns current value */ public void testIncrementAndGet() { - AtomicIntegerFieldUpdater a = AtomicIntegerFieldUpdater.newUpdater(getClass(), "x"); + AtomicIntegerFieldUpdater a; + try { + a = AtomicIntegerFieldUpdater.newUpdater(AtomicIntegerFieldUpdaterTest.class, "x"); + } catch (RuntimeException ok) { + return; + } x = 1; assertEquals(2,a.incrementAndGet(this)); assertEquals(2,a.get(this));