ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/PriorityBlockingQueueTest.java
(Generate patch)

Comparing jsr166/src/test/tck/PriorityBlockingQueueTest.java (file contents):
Revision 1.32 by jsr166, Tue Oct 19 00:43:49 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 {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines