ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicStampedReferenceTest.java
Revision: 1.9
Committed: Mon Nov 16 04:57:10 2009 UTC (14 years, 6 months ago) by jsr166
Branch: MAIN
Changes since 1.8: +6 -6 lines
Log Message: 
whitespace

File Contents

# User Rev Content
1 dl 1.1 /*
2 dl 1.5 * 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.8 * Other contributors include Andrew Wright, Jeffrey Hayes,
6     * Pat Fisher, Mike Judd.
7 dl 1.5 */
8 dl 1.1
9     import junit.framework.*;
10     import java.util.concurrent.atomic.*;
11    
12 dl 1.2 public class AtomicStampedReferenceTest extends JSR166TestCase{
13 dl 1.1 public static void main (String[] args) {
14     junit.textui.TestRunner.run (suite());
15     }
16     public static Test suite() {
17     return new TestSuite(AtomicStampedReferenceTest.class);
18     }
19 jsr166 1.8
20 dl 1.3 /**
21 dl 1.7 * constructor initializes to given reference and stamp
22 dl 1.3 */
23 dl 1.1 public void testConstructor(){
24     AtomicStampedReference ai = new AtomicStampedReference(one, 0);
25     assertEquals(one,ai.getReference());
26     assertEquals(0, ai.getStamp());
27     AtomicStampedReference a2 = new AtomicStampedReference(null, 1);
28     assertNull(a2.getReference());
29     assertEquals(1, a2.getStamp());
30    
31     }
32    
33 dl 1.3 /**
34 dl 1.4 * get returns the last values of reference and stamp set
35 dl 1.3 */
36 dl 1.1 public void testGetSet(){
37     int[] mark = new int[1];
38     AtomicStampedReference ai = new AtomicStampedReference(one, 0);
39     assertEquals(one,ai.getReference());
40     assertEquals(0, ai.getStamp());
41     assertEquals(one, ai.get(mark));
42     assertEquals(0, mark[0]);
43     ai.set(two, 0);
44     assertEquals(two,ai.getReference());
45     assertEquals(0, ai.getStamp());
46     assertEquals(two, ai.get(mark));
47     assertEquals(0, mark[0]);
48     ai.set(one, 1);
49     assertEquals(one,ai.getReference());
50     assertEquals(1, ai.getStamp());
51     assertEquals(one, ai.get(mark));
52     assertEquals(1,mark[0]);
53     }
54    
55 dl 1.3 /**
56 dl 1.4 * attemptStamp succeeds in single thread
57 dl 1.3 */
58 dl 1.1 public void testAttemptStamp(){
59     int[] mark = new int[1];
60     AtomicStampedReference ai = new AtomicStampedReference(one, 0);
61     assertEquals(0, ai.getStamp());
62     assertTrue(ai.attemptStamp(one, 1));
63     assertEquals(1, ai.getStamp());
64     assertEquals(one, ai.get(mark));
65     assertEquals(1, mark[0]);
66     }
67    
68 dl 1.3 /**
69 dl 1.4 * compareAndSet succeeds in changing values if equal to expected reference
70     * and stamp else fails
71 dl 1.3 */
72 dl 1.1 public void testCompareAndSet(){
73     int[] mark = new int[1];
74     AtomicStampedReference ai = new AtomicStampedReference(one, 0);
75     assertEquals(one, ai.get(mark));
76     assertEquals(0, ai.getStamp());
77     assertEquals(0, mark[0]);
78    
79     assertTrue(ai.compareAndSet(one, two, 0, 0));
80     assertEquals(two, ai.get(mark));
81     assertEquals(0, mark[0]);
82    
83     assertTrue(ai.compareAndSet(two, m3, 0, 1));
84     assertEquals(m3, ai.get(mark));
85     assertEquals(1, mark[0]);
86    
87     assertFalse(ai.compareAndSet(two, m3, 1, 1));
88     assertEquals(m3, ai.get(mark));
89     assertEquals(1, mark[0]);
90     }
91    
92 dl 1.3 /**
93 dl 1.4 * compareAndSet in one thread enables another waiting for reference value
94     * to succeed
95     */
96     public void testCompareAndSetInMultipleThreads() {
97     final AtomicStampedReference ai = new AtomicStampedReference(one, 0);
98     Thread t = new Thread(new Runnable() {
99     public void run() {
100 jsr166 1.9 while (!ai.compareAndSet(two, three, 0, 0)) Thread.yield();
101 dl 1.4 }});
102     try {
103     t.start();
104     assertTrue(ai.compareAndSet(one, two, 0, 0));
105     t.join(LONG_DELAY_MS);
106     assertFalse(t.isAlive());
107     assertEquals(ai.getReference(), three);
108     assertEquals(ai.getStamp(), 0);
109     }
110 jsr166 1.9 catch (Exception e) {
111 dl 1.4 unexpectedException();
112     }
113     }
114    
115     /**
116     * compareAndSet in one thread enables another waiting for stamp value
117     * to succeed
118     */
119     public void testCompareAndSetInMultipleThreads2() {
120     final AtomicStampedReference ai = new AtomicStampedReference(one, 0);
121     Thread t = new Thread(new Runnable() {
122     public void run() {
123 jsr166 1.9 while (!ai.compareAndSet(one, one, 1, 2)) Thread.yield();
124 dl 1.4 }});
125     try {
126     t.start();
127     assertTrue(ai.compareAndSet(one, one, 0, 1));
128     t.join(LONG_DELAY_MS);
129     assertFalse(t.isAlive());
130     assertEquals(ai.getReference(), one);
131     assertEquals(ai.getStamp(), 2);
132     }
133 jsr166 1.9 catch (Exception e) {
134 dl 1.4 unexpectedException();
135     }
136     }
137    
138     /**
139     * repeated weakCompareAndSet succeeds in changing values when equal
140 jsr166 1.8 * to expected
141 dl 1.3 */
142 dl 1.1 public void testWeakCompareAndSet(){
143     int[] mark = new int[1];
144     AtomicStampedReference ai = new AtomicStampedReference(one, 0);
145     assertEquals(one, ai.get(mark));
146     assertEquals(0, ai.getStamp ());
147     assertEquals(0, mark[0]);
148    
149 jsr166 1.9 while (!ai.weakCompareAndSet(one, two, 0, 0));
150 dl 1.1 assertEquals(two, ai.get(mark));
151     assertEquals(0, mark[0]);
152    
153 jsr166 1.9 while (!ai.weakCompareAndSet(two, m3, 0, 1));
154 dl 1.1 assertEquals(m3, ai.get(mark));
155     assertEquals(1, mark[0]);
156     }
157    
158     }