ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AtomicMarkableReferenceTest.java
Revision: 1.5
Committed: Sat Dec 27 19:26:43 2003 UTC (20 years, 4 months ago) by dl
Branch: MAIN
Changes since 1.4: +5 -4 lines
Log Message: 
Headers reference Creative Commons

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     * 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 dl 1.2 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    
20 dl 1.3 /**
21 dl 1.4 * constructeor initializes to given reference and mark
22 dl 1.3 */
23 dl 1.1 public void testConstructor(){
24     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 dl 1.1 public void testGetSet(){
37     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 dl 1.1 public void testAttemptMark(){
59     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 dl 1.1 public void testCompareAndSet(){
73     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     public void testCompareAndSetInMultipleThreads() {
97     final AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
98     Thread t = new Thread(new Runnable() {
99     public void run() {
100     while(!ai.compareAndSet(two, three, false, false)) Thread.yield();
101     }});
102     try {
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     }
110     catch(Exception e) {
111     unexpectedException();
112     }
113     }
114    
115     /**
116     * compareAndSet in one thread enables another waiting for mark value
117     * to succeed
118     */
119     public void testCompareAndSetInMultipleThreads2() {
120     final AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
121     Thread t = new Thread(new Runnable() {
122     public void run() {
123     while(!ai.compareAndSet(one, one, true, false)) Thread.yield();
124     }});
125     try {
126     t.start();
127     assertTrue(ai.compareAndSet(one, one, false, true));
128     t.join(LONG_DELAY_MS);
129     assertFalse(t.isAlive());
130     assertEquals(ai.getReference(), one);
131     assertFalse(ai.isMarked());
132     }
133     catch(Exception e) {
134     unexpectedException();
135     }
136     }
137    
138     /**
139     * repeated weakCompareAndSet succeeds in changing values when equal
140     * to expected
141 dl 1.3 */
142 dl 1.1 public void testWeakCompareAndSet(){
143     boolean[] mark = new boolean[1];
144     AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
145     assertEquals(one, ai.get(mark));
146     assertFalse(ai.isMarked());
147     assertFalse(mark[0]);
148    
149     while(!ai.weakCompareAndSet(one, two, false, false));
150     assertEquals(two, ai.get(mark));
151     assertFalse(mark[0]);
152    
153     while(!ai.weakCompareAndSet(two, m3, false, true));
154     assertEquals(m3, ai.get(mark));
155     assertTrue(mark[0]);
156     }
157    
158     }