ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicReferenceTest.java
Revision: 1.13
Committed: Tue Nov 17 06:58:50 2009 UTC (14 years, 5 months ago) by jsr166
Branch: MAIN
Changes since 1.12: +5 -4 lines
Log Message: 
Runnable => CheckedRunnable

File Contents

# User Rev Content
1 dl 1.1 /*
2 dl 1.6 * 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 jsr166 1.9 * Other contributors include Andrew Wright, Jeffrey Hayes,
6     * Pat Fisher, Mike Judd.
7 dl 1.1 */
8    
9     import junit.framework.*;
10     import java.util.concurrent.atomic.*;
11 dl 1.2 import java.io.*;
12 dl 1.1
13 dl 1.3 public class AtomicReferenceTest extends JSR166TestCase {
14 dl 1.1 public static void main (String[] args) {
15     junit.textui.TestRunner.run (suite());
16     }
17     public static Test suite() {
18     return new TestSuite(AtomicReferenceTest.class);
19     }
20    
21 dl 1.4 /**
22 dl 1.5 * constructor initializes to given value
23 dl 1.4 */
24 jsr166 1.11 public void testConstructor() {
25 dl 1.1 AtomicReference ai = new AtomicReference(one);
26     assertEquals(one,ai.get());
27     }
28    
29 dl 1.4 /**
30 dl 1.5 * default constructed initializes to null
31 dl 1.4 */
32 jsr166 1.11 public void testConstructor2() {
33 dl 1.1 AtomicReference ai = new AtomicReference();
34     assertNull(ai.get());
35     }
36    
37 dl 1.4 /**
38 dl 1.5 * get returns the last value set
39 dl 1.4 */
40 jsr166 1.11 public void testGetSet() {
41 dl 1.1 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());
47     }
48 dl 1.8
49     /**
50     * get returns the last value lazySet in same thread
51     */
52 jsr166 1.11 public void testGetLazySet() {
53 dl 1.8 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 dl 1.4 /**
62 dl 1.5 * compareAndSet succeeds in changing value if equal to expected else fails
63 dl 1.4 */
64 jsr166 1.11 public void testCompareAndSet() {
65 dl 1.1 AtomicReference ai = new AtomicReference(one);
66     assertTrue(ai.compareAndSet(one,two));
67     assertTrue(ai.compareAndSet(two,m4));
68     assertEquals(m4,ai.get());
69     assertFalse(ai.compareAndSet(m5,seven));
70     assertFalse((seven.equals(ai.get())));
71     assertTrue(ai.compareAndSet(m4,seven));
72     assertEquals(seven,ai.get());
73     }
74    
75 dl 1.4 /**
76 dl 1.5 * compareAndSet in one thread enables another waiting for value
77     * to succeed
78     */
79 jsr166 1.12 public void testCompareAndSetInMultipleThreads() throws Exception {
80 dl 1.5 final AtomicReference ai = new AtomicReference(one);
81 jsr166 1.13 Thread t = new Thread(new CheckedRunnable() {
82     public void realRun() {
83     while (!ai.compareAndSet(two, three))
84     Thread.yield();
85     }});
86 jsr166 1.12
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 dl 1.5 }
93    
94     /**
95     * repeated weakCompareAndSet succeeds in changing value when equal
96 jsr166 1.9 * to expected
97 dl 1.4 */
98 jsr166 1.11 public void testWeakCompareAndSet() {
99 dl 1.1 AtomicReference ai = new AtomicReference(one);
100 jsr166 1.10 while (!ai.weakCompareAndSet(one,two));
101     while (!ai.weakCompareAndSet(two,m4));
102 dl 1.1 assertEquals(m4,ai.get());
103 jsr166 1.10 while (!ai.weakCompareAndSet(m4,seven));
104 dl 1.1 assertEquals(seven,ai.get());
105     }
106    
107 dl 1.4 /**
108 dl 1.5 * getAndSet returns previous value and sets to given value
109 dl 1.4 */
110 jsr166 1.11 public void testGetAndSet() {
111 dl 1.1 AtomicReference ai = new AtomicReference(one);
112     assertEquals(one,ai.getAndSet(zero));
113     assertEquals(zero,ai.getAndSet(m10));
114     assertEquals(m10,ai.getAndSet(one));
115 dl 1.2 }
116    
117 dl 1.4 /**
118 dl 1.5 * a deserialized serialized atomic holds same value
119 dl 1.4 */
120 jsr166 1.12 public void testSerialization() throws Exception {
121 dl 1.2 AtomicReference l = new AtomicReference();
122    
123 jsr166 1.12 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 dl 1.1 }
134    
135 dl 1.7 /**
136     * toString returns current value.
137 jsr166 1.9 */
138 dl 1.7 public void testToString() {
139 jsr166 1.9 AtomicReference<Integer> ai = new AtomicReference<Integer>(one);
140 dl 1.7 assertEquals(ai.toString(), one.toString());
141     ai.set(two);
142     assertEquals(ai.toString(), two.toString());
143     }
144    
145 dl 1.1 }