ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicMarkableReferenceTest.java
Revision: 1.10
Committed: Tue Nov 17 03:12:51 2009 UTC (14 years, 6 months ago) by jsr166
Branch: MAIN
Changes since 1.9: +16 -24 lines
Log Message: 
nicer exception handling

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.7 * 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    
12 jsr166 1.9 public class AtomicMarkableReferenceTest 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(AtomicMarkableReferenceTest.class);
18     }
19 jsr166 1.7
20 dl 1.3 /**
21 dl 1.6 * constructor initializes to given reference and mark
22 dl 1.3 */
23 jsr166 1.9 public void testConstructor() {
24 dl 1.1 AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
25     assertEquals(one,ai.getReference());
26     assertFalse(ai.isMarked());
27     AtomicMarkableReference a2 = new AtomicMarkableReference(null, true);
28     assertNull(a2.getReference());
29     assertTrue(a2.isMarked());
30    
31     }
32    
33 dl 1.3 /**
34 dl 1.4 * get returns the last values of reference and mark set
35 dl 1.3 */
36 jsr166 1.9 public void testGetSet() {
37 dl 1.1 boolean[] mark = new boolean[1];
38     AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
39     assertEquals(one,ai.getReference());
40     assertFalse(ai.isMarked());
41     assertEquals(one, ai.get(mark));
42     assertFalse(mark[0]);
43     ai.set(two, false);
44     assertEquals(two,ai.getReference());
45     assertFalse(ai.isMarked());
46     assertEquals(two, ai.get(mark));
47     assertFalse(mark[0]);
48     ai.set(one, true);
49     assertEquals(one,ai.getReference());
50     assertTrue(ai.isMarked());
51     assertEquals(one, ai.get(mark));
52     assertTrue(mark[0]);
53     }
54    
55 dl 1.3 /**
56 dl 1.4 * attemptMark succeeds in single thread
57 dl 1.3 */
58 jsr166 1.9 public void testAttemptMark() {
59 dl 1.1 boolean[] mark = new boolean[1];
60     AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
61     assertFalse(ai.isMarked());
62     assertTrue(ai.attemptMark(one, true));
63     assertTrue(ai.isMarked());
64     assertEquals(one, ai.get(mark));
65     assertTrue(mark[0]);
66     }
67    
68 dl 1.3 /**
69 dl 1.4 * compareAndSet succeeds in changing values if equal to expected reference
70     * and mark else fails
71 dl 1.3 */
72 jsr166 1.9 public void testCompareAndSet() {
73 dl 1.1 boolean[] mark = new boolean[1];
74     AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
75     assertEquals(one, ai.get(mark));
76     assertFalse(ai.isMarked());
77     assertFalse(mark[0]);
78    
79     assertTrue(ai.compareAndSet(one, two, false, false));
80     assertEquals(two, ai.get(mark));
81     assertFalse(mark[0]);
82    
83     assertTrue(ai.compareAndSet(two, m3, false, true));
84     assertEquals(m3, ai.get(mark));
85     assertTrue(mark[0]);
86    
87     assertFalse(ai.compareAndSet(two, m3, true, true));
88     assertEquals(m3, ai.get(mark));
89     assertTrue(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 jsr166 1.10 public void testCompareAndSetInMultipleThreads() throws Exception {
97 dl 1.4 final AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
98     Thread t = new Thread(new Runnable() {
99     public void run() {
100 jsr166 1.8 while (!ai.compareAndSet(two, three, false, false)) Thread.yield();
101 dl 1.4 }});
102 jsr166 1.10
103     t.start();
104     assertTrue(ai.compareAndSet(one, two, false, false));
105     t.join(LONG_DELAY_MS);
106     assertFalse(t.isAlive());
107     assertEquals(ai.getReference(), three);
108     assertFalse(ai.isMarked());
109 dl 1.4 }
110    
111     /**
112     * compareAndSet in one thread enables another waiting for mark value
113     * to succeed
114     */
115 jsr166 1.10 public void testCompareAndSetInMultipleThreads2() throws Exception {
116 dl 1.4 final AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
117     Thread t = new Thread(new Runnable() {
118     public void run() {
119 jsr166 1.8 while (!ai.compareAndSet(one, one, true, false)) Thread.yield();
120 dl 1.4 }});
121 jsr166 1.10
122     t.start();
123     assertTrue(ai.compareAndSet(one, one, false, true));
124     t.join(LONG_DELAY_MS);
125     assertFalse(t.isAlive());
126     assertEquals(ai.getReference(), one);
127     assertFalse(ai.isMarked());
128 dl 1.4 }
129    
130     /**
131     * repeated weakCompareAndSet succeeds in changing values when equal
132 jsr166 1.7 * to expected
133 dl 1.3 */
134 jsr166 1.9 public void testWeakCompareAndSet() {
135 dl 1.1 boolean[] mark = new boolean[1];
136     AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
137     assertEquals(one, ai.get(mark));
138     assertFalse(ai.isMarked());
139     assertFalse(mark[0]);
140    
141 jsr166 1.8 while (!ai.weakCompareAndSet(one, two, false, false));
142 dl 1.1 assertEquals(two, ai.get(mark));
143     assertFalse(mark[0]);
144    
145 jsr166 1.8 while (!ai.weakCompareAndSet(two, m3, false, true));
146 dl 1.1 assertEquals(m3, ai.get(mark));
147     assertTrue(mark[0]);
148     }
149    
150     }