--- jsr166/src/test/tck/AtomicReferenceFieldUpdaterTest.java 2009/12/01 09:56:28 1.18 +++ jsr166/src/test/tck/AtomicReferenceFieldUpdaterTest.java 2013/04/01 20:58:58 1.26 @@ -1,14 +1,13 @@ /* * 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 + * http://creativecommons.org/publicdomain/zero/1.0/ * Other contributors include Andrew Wright, Jeffrey Hayes, * Pat Fisher, Mike Judd. */ -import java.util.concurrent.atomic.*; import junit.framework.*; -import java.util.*; +import java.util.concurrent.atomic.AtomicReferenceFieldUpdater; public class AtomicReferenceFieldUpdaterTest extends JSR166TestCase { volatile Integer x = null; @@ -22,27 +21,27 @@ public class AtomicReferenceFieldUpdater return new TestSuite(AtomicReferenceFieldUpdaterTest.class); } + AtomicReferenceFieldUpdater updaterFor(String fieldName) { + return AtomicReferenceFieldUpdater.newUpdater + (AtomicReferenceFieldUpdaterTest.class, Integer.class, fieldName); + } + /** * Construction with non-existent field throws RuntimeException */ public void testConstructor() { try { - AtomicReferenceFieldUpdater - a = AtomicReferenceFieldUpdater.newUpdater - (AtomicReferenceFieldUpdaterTest.class, Integer.class, "y"); + updaterFor("y"); shouldThrow(); } catch (RuntimeException success) {} } - /** * construction with field not of given type throws RuntimeException */ public void testConstructor2() { try { - AtomicReferenceFieldUpdater - a = AtomicReferenceFieldUpdater.newUpdater - (AtomicReferenceFieldUpdaterTest.class, Integer.class, "z"); + updaterFor("z"); shouldThrow(); } catch (RuntimeException success) {} } @@ -52,47 +51,37 @@ public class AtomicReferenceFieldUpdater */ public void testConstructor3() { try { - AtomicReferenceFieldUpdater - a = AtomicReferenceFieldUpdater.newUpdater - (AtomicReferenceFieldUpdaterTest.class, Integer.class, "w"); + updaterFor("w"); shouldThrow(); } catch (RuntimeException success) {} } /** - * get returns the last value set or assigned + * get returns the last value set or assigned */ public void testGetSet() { AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } + a = updaterFor("x"); x = one; - assertSame(one,a.get(this)); - a.set(this,two); - assertSame(two,a.get(this)); - a.set(this,m3); - assertSame(m3,a.get(this)); + assertSame(one, a.get(this)); + a.set(this, two); + assertSame(two, a.get(this)); + a.set(this, m3); + assertSame(m3, a.get(this)); } /** - * get returns the last value lazySet by same thread + * get returns the last value lazySet by same thread */ public void testGetLazySet() { AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } - x = one; - assertSame(one,a.get(this)); - a.lazySet(this,two); - assertSame(two,a.get(this)); - a.lazySet(this,m3); - assertSame(m3,a.get(this)); + a = updaterFor("x"); + x = one; + assertSame(one, a.get(this)); + a.lazySet(this, two); + assertSame(two, a.get(this)); + a.lazySet(this, m3); + assertSame(m3, a.get(this)); } /** @@ -100,19 +89,15 @@ public class AtomicReferenceFieldUpdater */ public void testCompareAndSet() { AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } - x = one; - assertTrue(a.compareAndSet(this,one,two)); - assertTrue(a.compareAndSet(this,two,m4)); - assertSame(m4,a.get(this)); - assertFalse(a.compareAndSet(this,m5,seven)); + a = updaterFor("x"); + x = one; + assertTrue(a.compareAndSet(this, one, two)); + assertTrue(a.compareAndSet(this, two, m4)); + assertSame(m4, a.get(this)); + assertFalse(a.compareAndSet(this, m5, seven)); assertFalse(seven == a.get(this)); - assertTrue(a.compareAndSet(this,m4,seven)); - assertSame(seven,a.get(this)); + assertTrue(a.compareAndSet(this, m4, seven)); + assertSame(seven, a.get(this)); } /** @@ -122,11 +107,7 @@ public class AtomicReferenceFieldUpdater public void testCompareAndSetInMultipleThreads() throws Exception { x = one; final AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } + a = updaterFor("x"); Thread t = new Thread(new CheckedRunnable() { public void realRun() { @@ -138,7 +119,7 @@ public class AtomicReferenceFieldUpdater assertTrue(a.compareAndSet(this, one, two)); t.join(LONG_DELAY_MS); assertFalse(t.isAlive()); - assertSame(a.get(this), three); + assertSame(three, a.get(this)); } /** @@ -147,17 +128,13 @@ public class AtomicReferenceFieldUpdater */ public void testWeakCompareAndSet() { AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } - x = one; - while (!a.weakCompareAndSet(this,one,two)); - while (!a.weakCompareAndSet(this,two,m4)); - assertSame(m4,a.get(this)); - while (!a.weakCompareAndSet(this,m4,seven)); - assertSame(seven,a.get(this)); + a = updaterFor("x"); + x = one; + while (!a.weakCompareAndSet(this, one, two)); + while (!a.weakCompareAndSet(this, two, m4)); + assertSame(m4, a.get(this)); + while (!a.weakCompareAndSet(this, m4, seven)); + assertSame(seven, a.get(this)); } /** @@ -165,15 +142,11 @@ public class AtomicReferenceFieldUpdater */ public void testGetAndSet() { AtomicReferenceFieldUpdatera; - try { - a = AtomicReferenceFieldUpdater.newUpdater(AtomicReferenceFieldUpdaterTest.class, Integer.class, "x"); - } catch (RuntimeException ok) { - return; - } - x = one; - assertSame(one,a.getAndSet(this, zero)); - assertSame(zero,a.getAndSet(this,m10)); - assertSame(m10,a.getAndSet(this,1)); + a = updaterFor("x"); + x = one; + assertSame(one, a.getAndSet(this, zero)); + assertSame(zero, a.getAndSet(this, m10)); + assertSame(m10, a.getAndSet(this, 1)); } }