ViewVC Help

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

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

Comparing jsr166/src/test/tck/LinkedBlockingQueueTest.java (file contents):
Revision 1.29 by jsr166, Wed Oct 6 07:49:22 2010 UTC vs.
Revision 1.32 by jsr166, Thu Oct 28 17:57:26 2010 UTC

#	Line 381 | Line 381 | public class LinkedBlockingQueueTest ext
381		}
382
383		/**
384	–	* take blocks interruptibly when empty
385	–	*/
386	–	public void testTakeFromEmpty() throws InterruptedException {
387	–	final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
388	–	Thread t = new ThreadShouldThrow(InterruptedException.class) {
389	–	public void realRun() throws InterruptedException {
390	–	q.take();
391	–	}};
392	–
393	–	t.start();
394	–	Thread.sleep(SHORT_DELAY_MS);
395	–	t.interrupt();
396	–	t.join();
397	–	}
398	–
399	–	/**
384		* Take removes existing elements until empty, then blocks interruptibly
385		*/
386		public void testBlockingTake() throws InterruptedException {
#	Line 895 | Line 879 | public class LinkedBlockingQueueTest ext
879		}
880
881		/**
882	<	* drainTo(c, n) empties first max {n, size} elements of queue into c
882	>	* drainTo(c, n) empties first min(n, size) elements of queue into c
883		*/
884		public void testDrainToN() {
885		LinkedBlockingQueue q = new LinkedBlockingQueue();
#	Line 904 | Line 888 | public class LinkedBlockingQueueTest ext
888		assertTrue(q.offer(new Integer(j)));
889		ArrayList l = new ArrayList();
890		q.drainTo(l, i);
891	<	int k = (i < SIZE)? i : SIZE;
891	>	int k = (i < SIZE) ? i : SIZE;
892		assertEquals(l.size(), k);
893		assertEquals(q.size(), SIZE-k);
894		for (int j = 0; j < k; ++j)

Diff Legend

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