ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicReferenceTest.java
(Generate patch)

Comparing jsr166/src/test/tck/AtomicReferenceTest.java (file contents):
Revision 1.5 by dl, Thu Sep 25 11:02:41 2003 UTC vs.
Revision 1.13 by jsr166, Tue Nov 17 06:58:50 2009 UTC

# Line 1 | Line 1
1   /*
2 < * Written by members of JCP JSR-166 Expert Group and released to the
3 < * public domain. Use, modify, and redistribute this code in any way
4 < * without acknowledgement. Other contributors include Andrew Wright,
5 < * Jeffrey Hayes, Pat Fischer, Mike Judd.
2 > * Written by Doug Lea with assistance from members of JCP JSR-166
3 > * Expert Group and released to the public domain, as explained at
4 > * http://creativecommons.org/licenses/publicdomain
5 > * Other contributors include Andrew Wright, Jeffrey Hayes,
6 > * Pat Fisher, Mike Judd.
7   */
8  
9   import junit.framework.*;
# Line 20 | Line 21 | public class AtomicReferenceTest extends
21      /**
22       * constructor initializes to given value
23       */
24 <    public void testConstructor(){
24 >    public void testConstructor() {
25          AtomicReference ai = new AtomicReference(one);
26          assertEquals(one,ai.get());
27      }
# Line 28 | Line 29 | public class AtomicReferenceTest extends
29      /**
30       * default constructed initializes to null
31       */
32 <    public void testConstructor2(){
32 >    public void testConstructor2() {
33          AtomicReference ai = new AtomicReference();
34          assertNull(ai.get());
35      }
# Line 36 | Line 37 | public class AtomicReferenceTest extends
37      /**
38       * get returns the last value set
39       */
40 <    public void testGetSet(){
40 >    public void testGetSet() {
41          AtomicReference ai = new AtomicReference(one);
42          assertEquals(one,ai.get());
43          ai.set(two);
44          assertEquals(two,ai.get());
45          ai.set(m3);
46          assertEquals(m3,ai.get());
46        
47      }
48 +
49 +    /**
50 +     * get returns the last value lazySet in same thread
51 +     */
52 +    public void testGetLazySet() {
53 +        AtomicReference ai = new AtomicReference(one);
54 +        assertEquals(one,ai.get());
55 +        ai.lazySet(two);
56 +        assertEquals(two,ai.get());
57 +        ai.lazySet(m3);
58 +        assertEquals(m3,ai.get());
59 +    }
60 +
61      /**
62       * compareAndSet succeeds in changing value if equal to expected else fails
63       */
64 <    public void testCompareAndSet(){
64 >    public void testCompareAndSet() {
65          AtomicReference ai = new AtomicReference(one);
66          assertTrue(ai.compareAndSet(one,two));
67          assertTrue(ai.compareAndSet(two,m4));
# Line 63 | Line 76 | public class AtomicReferenceTest extends
76       * compareAndSet in one thread enables another waiting for value
77       * to succeed
78       */
79 <    public void testCompareAndSetInMultipleThreads() {
79 >    public void testCompareAndSetInMultipleThreads() throws Exception {
80          final AtomicReference ai = new AtomicReference(one);
81 <        Thread t = new Thread(new Runnable() {
82 <                public void run() {
83 <                    while(!ai.compareAndSet(two, three)) Thread.yield();
84 <                }});
85 <        try {
86 <            t.start();
87 <            assertTrue(ai.compareAndSet(one, two));
88 <            t.join(LONG_DELAY_MS);
89 <            assertFalse(t.isAlive());
90 <            assertEquals(ai.get(), three);
91 <        }
79 <        catch(Exception e) {
80 <            unexpectedException();
81 <        }
81 >        Thread t = new Thread(new CheckedRunnable() {
82 >            public void realRun() {
83 >                while (!ai.compareAndSet(two, three))
84 >                    Thread.yield();
85 >            }});
86 >
87 >        t.start();
88 >        assertTrue(ai.compareAndSet(one, two));
89 >        t.join(LONG_DELAY_MS);
90 >        assertFalse(t.isAlive());
91 >        assertEquals(ai.get(), three);
92      }
93  
94      /**
95       * repeated weakCompareAndSet succeeds in changing value when equal
96 <     * to expected
96 >     * to expected
97       */
98 <    public void testWeakCompareAndSet(){
98 >    public void testWeakCompareAndSet() {
99          AtomicReference ai = new AtomicReference(one);
100 <        while(!ai.weakCompareAndSet(one,two));
101 <        while(!ai.weakCompareAndSet(two,m4));
100 >        while (!ai.weakCompareAndSet(one,two));
101 >        while (!ai.weakCompareAndSet(two,m4));
102          assertEquals(m4,ai.get());
103 <        while(!ai.weakCompareAndSet(m4,seven));
103 >        while (!ai.weakCompareAndSet(m4,seven));
104          assertEquals(seven,ai.get());
105      }
106  
107      /**
108       * getAndSet returns previous value and sets to given value
109       */
110 <    public void testGetAndSet(){
110 >    public void testGetAndSet() {
111          AtomicReference ai = new AtomicReference(one);
112          assertEquals(one,ai.getAndSet(zero));
113          assertEquals(zero,ai.getAndSet(m10));
# Line 107 | Line 117 | public class AtomicReferenceTest extends
117      /**
118       * a deserialized serialized atomic holds same value
119       */
120 <    public void testSerialization() {
120 >    public void testSerialization() throws Exception {
121          AtomicReference l = new AtomicReference();
122  
123 <        try {
124 <            l.set(one);
125 <            ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
126 <            ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
127 <            out.writeObject(l);
128 <            out.close();
129 <
130 <            ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
131 <            ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
132 <            AtomicReference r = (AtomicReference) in.readObject();
123 <            assertEquals(l.get(), r.get());
124 <        } catch(Exception e){
125 <            unexpectedException();
126 <        }
123 >        l.set(one);
124 >        ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
125 >        ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
126 >        out.writeObject(l);
127 >        out.close();
128 >
129 >        ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
130 >        ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
131 >        AtomicReference r = (AtomicReference) in.readObject();
132 >        assertEquals(l.get(), r.get());
133      }
134  
135 < }
135 >    /**
136 >     * toString returns current value.
137 >     */
138 >    public void testToString() {
139 >        AtomicReference<Integer> ai = new AtomicReference<Integer>(one);
140 >        assertEquals(ai.toString(), one.toString());
141 >        ai.set(two);
142 >        assertEquals(ai.toString(), two.toString());
143 >    }
144  
145 + }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines