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.41 by jsr166, Tue Mar 15 19:47:07 2011 UTC vs.
Revision 1.43 by dl, Fri May 6 11:22:07 2011 UTC

# Line 296 | Line 296 | public class PriorityBlockingQueueTest e
296      /**
297       * put(null) throws NPE
298       */
299 <     public void testPutNull() {
299 >    public void testPutNull() {
300          try {
301              PriorityBlockingQueue q = new PriorityBlockingQueue(SIZE);
302              q.put(null);
303              shouldThrow();
304          } catch (NullPointerException success) {}
305 <     }
305 >    }
306  
307      /**
308       * all elements successfully put are contained
309       */
310 <     public void testPut() {
311 <         PriorityBlockingQueue q = new PriorityBlockingQueue(SIZE);
312 <         for (int i = 0; i < SIZE; ++i) {
313 <             Integer I = new Integer(i);
314 <             q.put(I);
315 <             assertTrue(q.contains(I));
316 <         }
317 <         assertEquals(SIZE, q.size());
310 >    public void testPut() {
311 >        PriorityBlockingQueue q = new PriorityBlockingQueue(SIZE);
312 >        for (int i = 0; i < SIZE; ++i) {
313 >            Integer I = new Integer(i);
314 >            q.put(I);
315 >            assertTrue(q.contains(I));
316 >        }
317 >        assertEquals(SIZE, q.size());
318      }
319  
320      /**
# Line 330 | Line 330 | public class PriorityBlockingQueueTest e
330              }});
331  
332          t.start();
333 <        Thread.sleep(SHORT_DELAY_MS);
333 >        delay(SHORT_DELAY_MS);
334          assertEquals(q.size(), size);
335          q.take();
336          t.interrupt();
# Line 351 | Line 351 | public class PriorityBlockingQueueTest e
351              }});
352  
353          t.start();
354 <        Thread.sleep(SMALL_DELAY_MS);
354 >        delay(SMALL_DELAY_MS);
355          t.interrupt();
356          t.join();
357      }
# Line 383 | Line 383 | public class PriorityBlockingQueueTest e
383              }});
384  
385          t.start();
386 <        Thread.sleep(SHORT_DELAY_MS);
386 >        delay(SHORT_DELAY_MS);
387          t.interrupt();
388          t.join();
389      }
# Line 698 | Line 698 | public class PriorityBlockingQueueTest e
698  
699          executor.execute(new CheckedRunnable() {
700              public void realRun() throws InterruptedException {
701 <                Thread.sleep(SMALL_DELAY_MS);
701 >                delay(SMALL_DELAY_MS);
702                  q.put(one);
703              }});
704  

Diff Legend

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