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.9 by jsr166, Mon Nov 16 05:30:07 2009 UTC vs.
Revision 1.10 by jsr166, Tue Nov 17 03:12:51 2009 UTC

#	Line 93 | 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();
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	<	}
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();
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());
132	<	}
133	<	catch (Exception e) {
134	<	unexpectedException();
135	<	}
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		/**

Diff Legend

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