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.65 by jsr166, Sun Oct 4 18:49:02 2015 UTC vs.
Revision 1.70 by jsr166, Tue Nov 22 16:48:36 2016 UTC

# Line 42 | Line 42 | public class PriorityBlockingQueueTest e
42      }
43  
44      public static Test suite() {
45 +        class Implementation implements CollectionImplementation {
46 +            public Class<?> klazz() { return PriorityBlockingQueue.class; }
47 +            public Collection emptyCollection() { return new PriorityBlockingQueue(); }
48 +            public Object makeElement(int i) { return i; }
49 +            public boolean isConcurrent() { return true; }
50 +            public boolean permitsNulls() { return false; }
51 +        }
52          return newTestSuite(PriorityBlockingQueueTest.class,
53                              new Generic().testSuite(),
54 <                            new InitialCapacity().testSuite());
54 >                            new InitialCapacity().testSuite(),
55 >                            CollectionTest.testSuite(new Implementation()));
56      }
57  
58      /** Sample Comparator */
# Line 56 | Line 64 | public class PriorityBlockingQueueTest e
64  
65      /**
66       * Returns a new queue of given size containing consecutive
67 <     * Integers 0 ... n.
67 >     * Integers 0 ... n - 1.
68       */
69      private PriorityBlockingQueue<Integer> populatedQueue(int n) {
70          PriorityBlockingQueue<Integer> q =
# Line 69 | Line 77 | public class PriorityBlockingQueueTest e
77          assertFalse(q.isEmpty());
78          assertEquals(Integer.MAX_VALUE, q.remainingCapacity());
79          assertEquals(n, q.size());
80 +        assertEquals((Integer) 0, q.peek());
81          return q;
82      }
83  
# Line 200 | Line 209 | public class PriorityBlockingQueueTest e
209          PriorityBlockingQueue q = new PriorityBlockingQueue(1);
210          try {
211              q.offer(new Object());
203 –            q.offer(new Object());
212              shouldThrow();
213 <        } catch (ClassCastException success) {}
213 >        } catch (ClassCastException success) {
214 >            assertTrue(q.isEmpty());
215 >            assertEquals(0, q.size());
216 >            assertNull(q.poll());
217 >        }
218      }
219  
220      /**
# Line 393 | Line 405 | public class PriorityBlockingQueueTest e
405          final CountDownLatch aboutToWait = new CountDownLatch(1);
406          Thread t = newStartedThread(new CheckedRunnable() {
407              public void realRun() throws InterruptedException {
408 +                long startTime = System.nanoTime();
409                  for (int i = 0; i < SIZE; ++i) {
397 –                    long t0 = System.nanoTime();
410                      assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
399 –                    assertTrue(millisElapsedSince(t0) < SMALL_DELAY_MS);
411                  }
401 –                long t0 = System.nanoTime();
412                  aboutToWait.countDown();
413                  try {
414                      q.poll(LONG_DELAY_MS, MILLISECONDS);
415                      shouldThrow();
416                  } catch (InterruptedException success) {
417 <                    assertTrue(millisElapsedSince(t0) < MEDIUM_DELAY_MS);
417 >                    assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
418                  }
419              }});
420  
421          aboutToWait.await();
422 <        waitForThreadToEnterWaitState(t, SMALL_DELAY_MS);
422 >        waitForThreadToEnterWaitState(t);
423          t.interrupt();
424 <        awaitTermination(t, MEDIUM_DELAY_MS);
424 >        awaitTermination(t);
425      }
426  
427      /**

Diff Legend

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