ViewVC Help

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

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

Comparing jsr166/src/test/tck/SynchronousQueueTest.java (file contents):
Revision 1.56 by jsr166, Sun May 14 00:56:43 2017 UTC vs.
Revision 1.57 by jsr166, Sun May 14 03:48:35 2017 UTC

#	Line 18 | Line 18 | import java.util.concurrent.CountDownLat
18		import java.util.concurrent.Executors;
19		import java.util.concurrent.ExecutorService;
20		import java.util.concurrent.SynchronousQueue;
21	+	import java.util.concurrent.ThreadLocalRandom;
22
23		import junit.framework.Test;
24
#	Line 181 | Line 182 | public class SynchronousQueueTest extend
182		/**
183		* timed offer times out if elements not taken
184		*/
185	<	public void testTimedOffer()      { testTimedOffer(false); }
186	<	public void testTimedOffer_fair() { testTimedOffer(true); }
186	<	public void testTimedOffer(boolean fair) {
185	>	public void testTimedOffer() {
186	>	final boolean fair = ThreadLocalRandom.current().nextBoolean();
187		final SynchronousQueue q = new SynchronousQueue(fair);
188		final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
189		Thread t = newStartedThread(new CheckedRunnable() {
#	Line 229 | Line 229 | public class SynchronousQueueTest extend
229		/**
230		* timed poll with nonzero timeout times out if no active putter
231		*/
232	<	public void testTimedPoll()      { testTimedPoll(false); }
233	<	public void testTimedPoll_fair() { testTimedPoll(true); }
234	<	public void testTimedPoll(boolean fair) {
232	>	public void testTimedPoll() {
233	>	final boolean fair = ThreadLocalRandom.current().nextBoolean();
234		final SynchronousQueue q = new SynchronousQueue(fair);
235	<	long startTime = System.nanoTime();
235	>	final long startTime = System.nanoTime();
236		try { assertNull(q.poll(timeoutMillis(), MILLISECONDS)); }
237		catch (InterruptedException e) { threadUnexpectedException(e); }
238		assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
#	Line 243 | Line 242 | public class SynchronousQueueTest extend
242		* timed poll before a delayed offer times out, returning null;
243		* after offer succeeds; on interruption throws
244		*/
245	<	public void testTimedPollWithOffer()      { testTimedPollWithOffer(false); }
246	<	public void testTimedPollWithOffer_fair() { testTimedPollWithOffer(true); }
248	<	public void testTimedPollWithOffer(boolean fair) {
245	>	public void testTimedPollWithOffer() {
246	>	final boolean fair = ThreadLocalRandom.current().nextBoolean();
247		final SynchronousQueue q = new SynchronousQueue(fair);
248		final CountDownLatch pleaseOffer = new CountDownLatch(1);
249		final CountDownLatch pleaseInterrupt = new CountDownLatch(1);

Diff Legend

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