ViewVC Help

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

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

Comparing jsr166/src/test/tck/PriorityBlockingQueueTest.java (file contents):
Revision 1.75 by jsr166, Sun May 14 00:48:20 2017 UTC vs.
Revision 1.78 by jsr166, Mon May 29 22:44:27 2017 UTC

#	Line 90 | Line 90 | public class PriorityBlockingQueueTest e
90		}
91
92		/**
93	<	* Constructor throws IAE if capacity argument nonpositive
93	>	* Constructor throws IllegalArgumentException if capacity argument nonpositive
94		*/
95		public void testConstructor2() {
96		try {
#	Line 229 | Line 229 | public class PriorityBlockingQueueTest e
229		}
230
231		/**
232	<	* addAll(this) throws IAE
232	>	* addAll(this) throws IllegalArgumentException
233		*/
234		public void testAddAllSelf() {
235		PriorityBlockingQueue q = populatedQueue(SIZE);
#	Line 302 | Line 302 | public class PriorityBlockingQueueTest e
302		/**
303		* timed offer does not time out
304		*/
305	<	public void testTimedOffer() throws InterruptedException {
305	>	public void testTimedOffer() {
306		final PriorityBlockingQueue q = new PriorityBlockingQueue(2);
307		Thread t = newStartedThread(new CheckedRunnable() {
308		public void realRun() {
#	Line 404 | Line 404 | public class PriorityBlockingQueueTest e
404		Thread t = newStartedThread(new CheckedRunnable() {
405		public void realRun() throws InterruptedException {
406		long startTime = System.nanoTime();
407	<	for (int i = 0; i < SIZE; ++i) {
407	>	for (int i = 0; i < SIZE; i++)
408		assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
409	<	}
409	>
410	>	Thread.currentThread().interrupt();
411	>	try {
412	>	q.poll(LONG_DELAY_MS, MILLISECONDS);
413	>	shouldThrow();
414	>	} catch (InterruptedException success) {}
415	>	assertFalse(Thread.interrupted());
416
417		pleaseInterrupt.countDown();
418		try {

Diff Legend

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