ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/AtomicStampedReferenceTest.java

Comparing jsr166/src/test/tck/AtomicStampedReferenceTest.java (file contents):
Revision 1.6 by dl, Sun Dec 28 21:56:18 2003 UTC vs.
Revision 1.11 by jsr166, Tue Nov 17 03:12:51 2009 UTC

#	Line 2 | Line 2
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.
5	>	* Other contributors include Andrew Wright, Jeffrey Hayes,
6	>	* Pat Fisher, Mike Judd.
7		*/
8
9		import junit.framework.*;
10		import java.util.concurrent.atomic.*;
11
12	<	public class AtomicStampedReferenceTest extends JSR166TestCase{
12	>	public class AtomicStampedReferenceTest extends JSR166TestCase {
13		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	<
19	>
20		/**
21	<	* constructeor initializes to given reference and stamp
21	>	* constructor initializes to given reference and stamp
22		*/
23	<	public void testConstructor(){
23	>	public void testConstructor() {
24		AtomicStampedReference ai = new AtomicStampedReference(one, 0);
25		assertEquals(one,ai.getReference());
26		assertEquals(0, ai.getStamp());
#	Line 33 | Line 33 | public class AtomicStampedReferenceTest
33		/**
34		*  get returns the last values of reference and stamp set
35		*/
36	<	public void testGetSet(){
36	>	public void testGetSet() {
37		int[] mark = new int[1];
38		AtomicStampedReference ai = new AtomicStampedReference(one, 0);
39		assertEquals(one,ai.getReference());
#	Line 55 | Line 55 | public class AtomicStampedReferenceTest
55		/**
56		*  attemptStamp succeeds in single thread
57		*/
58	<	public void testAttemptStamp(){
58	>	public void testAttemptStamp() {
59		int[] mark = new int[1];
60		AtomicStampedReference ai = new AtomicStampedReference(one, 0);
61		assertEquals(0, ai.getStamp());
#	Line 69 | Line 69 | public class AtomicStampedReferenceTest
69		* compareAndSet succeeds in changing values if equal to expected reference
70		* and stamp else fails
71		*/
72	<	public void testCompareAndSet(){
72	>	public void testCompareAndSet() {
73		int[] mark = new int[1];
74		AtomicStampedReference ai = new AtomicStampedReference(one, 0);
75		assertEquals(one, ai.get(mark));
#	Line 93 | Line 93 | public class AtomicStampedReferenceTest
93		* compareAndSet in one thread enables another waiting for reference value
94		* to succeed
95		*/
96	<	public void testCompareAndSetInMultipleThreads() {
96	>	public void testCompareAndSetInMultipleThreads() throws Exception {
97		final AtomicStampedReference ai = new AtomicStampedReference(one, 0);
98		Thread t = new Thread(new Runnable() {
99		public void run() {
100	<	while(!ai.compareAndSet(two, three, 0, 0)) Thread.yield();
100	>	while (!ai.compareAndSet(two, three, 0, 0)) Thread.yield();
101		}});
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	<	catch(Exception e) {
111	<	unexpectedException();
112	<	}
102	>
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
111		/**
112		* compareAndSet in one thread enables another waiting for stamp value
113		* to succeed
114		*/
115	<	public void testCompareAndSetInMultipleThreads2() {
115	>	public void testCompareAndSetInMultipleThreads2() throws Exception {
116		final AtomicStampedReference ai = new AtomicStampedReference(one, 0);
117		Thread t = new Thread(new Runnable() {
118		public void run() {
119	<	while(!ai.compareAndSet(one, one, 1, 2)) Thread.yield();
119	>	while (!ai.compareAndSet(one, one, 1, 2)) Thread.yield();
120		}});
121	<	try {
122	<	t.start();
123	<	assertTrue(ai.compareAndSet(one, one, 0, 1));
124	<	t.join(LONG_DELAY_MS);
125	<	assertFalse(t.isAlive());
126	<	assertEquals(ai.getReference(), one);
127	<	assertEquals(ai.getStamp(), 2);
132	<	}
133	<	catch(Exception e) {
134	<	unexpectedException();
135	<	}
121	>
122	>	t.start();
123	>	assertTrue(ai.compareAndSet(one, one, 0, 1));
124	>	t.join(LONG_DELAY_MS);
125	>	assertFalse(t.isAlive());
126	>	assertEquals(ai.getReference(), one);
127	>	assertEquals(ai.getStamp(), 2);
128		}
129
130		/**
131		* repeated weakCompareAndSet succeeds in changing values when equal
132	<	* to expected
132	>	* to expected
133		*/
134	<	public void testWeakCompareAndSet(){
134	>	public void testWeakCompareAndSet() {
135		int[] mark = new int[1];
136		AtomicStampedReference ai = new AtomicStampedReference(one, 0);
137		assertEquals(one, ai.get(mark));
138		assertEquals(0, ai.getStamp ());
139		assertEquals(0, mark[0]);
140
141	<	while(!ai.weakCompareAndSet(one, two, 0, 0));
141	>	while (!ai.weakCompareAndSet(one, two, 0, 0));
142		assertEquals(two, ai.get(mark));
143		assertEquals(0, mark[0]);
144
145	<	while(!ai.weakCompareAndSet(two, m3, 0, 1));
145	>	while (!ai.weakCompareAndSet(two, m3, 0, 1));
146		assertEquals(m3, ai.get(mark));
147		assertEquals(1, mark[0]);
148		}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines