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.30 by jsr166, Sat Oct 9 19:30:35 2010 UTC vs.
Revision 1.33 by jsr166, Thu Oct 28 17:57:26 2010 UTC

#	Line 366 | Line 366 | public class PriorityBlockingQueueTest e
366		}
367
368		/**
369	–	* take blocks interruptibly when empty
370	–	*/
371	–	public void testTakeFromEmpty() throws InterruptedException {
372	–	final PriorityBlockingQueue q = new PriorityBlockingQueue(2);
373	–	Thread t = new Thread(new CheckedInterruptedRunnable() {
374	–	public void realRun() throws InterruptedException {
375	–	q.take();
376	–	}});
377	–
378	–	t.start();
379	–	Thread.sleep(SHORT_DELAY_MS);
380	–	t.interrupt();
381	–	t.join();
382	–	}
383	–
384	–	/**
369		* Take removes existing elements until empty, then blocks interruptibly
370		*/
371		public void testBlockingTake() throws InterruptedException {
#	Line 813 | Line 797 | public class PriorityBlockingQueueTest e
797		}
798
799		/**
800	<	* drainTo(c, n) empties first max {n, size} elements of queue into c
800	>	* drainTo(c, n) empties first min(n, size) elements of queue into c
801		*/
802		public void testDrainToN() {
803		PriorityBlockingQueue q = new PriorityBlockingQueue(SIZE*2);
#	Line 822 | Line 806 | public class PriorityBlockingQueueTest e
806		assertTrue(q.offer(new Integer(j)));
807		ArrayList l = new ArrayList();
808		q.drainTo(l, i);
809	<	int k = (i < SIZE)? i : SIZE;
809	>	int k = (i < SIZE) ? i : SIZE;
810		assertEquals(l.size(), k);
811		assertEquals(q.size(), SIZE-k);
812		for (int j = 0; j < k; ++j)

Diff Legend

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