ViewVC Help

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

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

Comparing jsr166/src/test/tck/AtomicMarkableReferenceTest.java (file contents):
Revision 1.4 by dl, Thu Sep 25 11:02:41 2003 UTC vs.
Revision 1.10 by jsr166, Tue Nov 17 03:12:51 2009 UTC

#	Line 1 | Line 1
1		/*
2	<	* Written by members of JCP JSR-166 Expert Group and released to the
3	<	* public domain. Use, modify, and redistribute this code in any way
4	<	* without acknowledgement. Other contributors include Andrew Wright,
5	<	* Jeffrey Hayes, Pat Fischer, Mike Judd.
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.
7		*/
8
9		import junit.framework.*;
10		import java.util.concurrent.atomic.*;
11
12	<	public class AtomicMarkableReferenceTest extends JSR166TestCase{
12	>	public class AtomicMarkableReferenceTest 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(AtomicMarkableReferenceTest.class);
18		}
19	<
19	>
20		/**
21	<	*  constructeor initializes to given reference and mark
21	>	*  constructor initializes to given reference and mark
22		*/
23	<	public void testConstructor(){
23	>	public void testConstructor() {
24		AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
25		assertEquals(one,ai.getReference());
26		assertFalse(ai.isMarked());
#	Line 32 | Line 33 | public class AtomicMarkableReferenceTest
33		/**
34		*  get returns the last values of reference and mark set
35		*/
36	<	public void testGetSet(){
36	>	public void testGetSet() {
37		boolean[] mark = new boolean[1];
38		AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
39		assertEquals(one,ai.getReference());
#	Line 54 | Line 55 | public class AtomicMarkableReferenceTest
55		/**
56		* attemptMark succeeds in single thread
57		*/
58	<	public void testAttemptMark(){
58	>	public void testAttemptMark() {
59		boolean[] mark = new boolean[1];
60		AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
61		assertFalse(ai.isMarked());
#	Line 68 | Line 69 | public class AtomicMarkableReferenceTest
69		* compareAndSet succeeds in changing values if equal to expected reference
70		* and mark else fails
71		*/
72	<	public void testCompareAndSet(){
72	>	public void testCompareAndSet() {
73		boolean[] mark = new boolean[1];
74		AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
75		assertEquals(one, ai.get(mark));
#	Line 92 | Line 93 | public class AtomicMarkableReferenceTest
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 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();
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());
108	<	}
109	<	catch(Exception e) {
110	<	unexpectedException();
111	<	}
102	>
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
111		/**
112		* compareAndSet in one thread enables another waiting for mark value
113		* to succeed
114		*/
115	<	public void testCompareAndSetInMultipleThreads2() {
115	>	public void testCompareAndSetInMultipleThreads2() throws Exception {
116		final AtomicMarkableReference ai = new AtomicMarkableReference(one, false);
117		Thread t = new Thread(new Runnable() {
118		public void run() {
119	<	while(!ai.compareAndSet(one, one, true, false)) Thread.yield();
119	>	while (!ai.compareAndSet(one, one, true, false)) Thread.yield();
120		}});
121	<	try {
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());
131	<	}
132	<	catch(Exception e) {
133	<	unexpectedException();
134	<	}
121	>
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		}
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		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	<	while(!ai.weakCompareAndSet(one, two, false, false));
141	>	while (!ai.weakCompareAndSet(one, two, false, false));
142		assertEquals(two, ai.get(mark));
143		assertFalse(mark[0]);
144
145	<	while(!ai.weakCompareAndSet(two, m3, false, true));
145	>	while (!ai.weakCompareAndSet(two, m3, false, true));
146		assertEquals(m3, ai.get(mark));
147		assertTrue(mark[0]);
148		}

Diff Legend

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