ViewVC Help

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

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

Comparing jsr166/src/test/tck/CyclicBarrierTest.java (file contents):
Revision 1.24 by jsr166, Tue May 31 16:16:23 2011 UTC vs.
Revision 1.28 by jsr166, Thu Sep 15 01:18:01 2016 UTC

#	Line 6 | Line 6
6		* Pat Fisher, Mike Judd.
7		*/
8
9	<	import junit.framework.*;
10	<	import java.util.*;
9	>	import static java.util.concurrent.TimeUnit.MILLISECONDS;
10	>
11		import java.util.concurrent.BrokenBarrierException;
12		import java.util.concurrent.CountDownLatch;
13		import java.util.concurrent.CyclicBarrier;
14		import java.util.concurrent.TimeoutException;
15		import java.util.concurrent.atomic.AtomicBoolean;
16	<	import static java.util.concurrent.TimeUnit.MILLISECONDS;
16	>	import java.util.concurrent.atomic.AtomicInteger;
17	>
18	>	import junit.framework.Test;
19	>	import junit.framework.TestSuite;
20
21		public class CyclicBarrierTest extends JSR166TestCase {
22		public static void main(String[] args) {
23	<	junit.textui.TestRunner.run(suite());
23	>	main(suite(), args);
24		}
25		public static Test suite() {
26		return new TestSuite(CyclicBarrierTest.class);
27		}
28
26	–	private volatile int countAction;
27	–	private class MyAction implements Runnable {
28	–	public void run() { ++countAction; }
29	–	}
30	–
29		/**
30		* Spin-waits till the number of waiters == numberOfWaiters.
31		*/
#	Line 85 | Line 83 | public class CyclicBarrierTest extends J
83		* The supplied barrier action is run at barrier
84		*/
85		public void testBarrierAction() throws Exception {
86	<	countAction = 0;
87	<	CyclicBarrier b = new CyclicBarrier(1, new MyAction());
86	>	final AtomicInteger count = new AtomicInteger(0);
87	>	final Runnable incCount = new Runnable() { public void run() {
88	>	count.getAndIncrement(); }};
89	>	CyclicBarrier b = new CyclicBarrier(1, incCount);
90		assertEquals(1, b.getParties());
91		assertEquals(0, b.getNumberWaiting());
92		b.await();
93		b.await();
94		assertEquals(0, b.getNumberWaiting());
95	<	assertEquals(countAction, 2);
95	>	assertEquals(2, count.get());
96		}
97
98		/**

Diff Legend

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