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

Comparing jsr166/src/test/tck/ArrayBlockingQueueTest.java (file contents):
Revision 1.31 by dl, Wed Sep 29 12:33:48 2010 UTC vs.
Revision 1.32 by jsr166, Wed Oct 6 07:49:22 2010 UTC

# Line 14 | Line 14 | import static java.util.concurrent.TimeU
14   import java.io.*;
15  
16   public class ArrayBlockingQueueTest extends JSR166TestCase {
17 +
18 +    public static class Fair extends BlockingQueueTest {
19 +        protected BlockingQueue emptyCollection() {
20 +            return new ArrayBlockingQueue(20, true);
21 +        }
22 +    }
23 +
24 +    public static class NonFair extends BlockingQueueTest {
25 +        protected BlockingQueue emptyCollection() {
26 +            return new ArrayBlockingQueue(20, false);
27 +        }
28 +    }
29 +
30      public static void main(String[] args) {
31          junit.textui.TestRunner.run(suite());
32      }
33 +
34      public static Test suite() {
35 <        return new TestSuite(ArrayBlockingQueueTest.class);
35 >        return newTestSuite(ArrayBlockingQueueTest.class,
36 >                            new Fair().testSuite(),
37 >                            new NonFair().testSuite());
38      }
39  
40      /**
# Line 472 | Line 488 | public class ArrayBlockingQueueTest exte
488      }
489  
490      /**
475 –     *  timed poll before a delayed offer fails; after offer succeeds;
476 –     *  on interruption throws
477 –     */
478 –    public void testTimedPollWithOffer() throws InterruptedException {
479 –        final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
480 –        Thread t = new Thread(new CheckedRunnable() {
481 –            public void realRun() throws InterruptedException {
482 –                try {
483 –                    assertNull(q.poll(SHORT_DELAY_MS, MILLISECONDS));
484 –                    assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS));
485 –                    q.poll(LONG_DELAY_MS, MILLISECONDS);
486 –                    shouldThrow();
487 –                } catch (InterruptedException success) {}
488 –            }});
489 –
490 –        t.start();
491 –        Thread.sleep(SMALL_DELAY_MS);
492 –        assertTrue(q.offer(zero, SHORT_DELAY_MS, MILLISECONDS));
493 –        t.interrupt();
494 –        t.join();
495 –    }
496 –
497 –
498 –    /**
491       * peek returns next element, or null if empty
492       */
493      public void testPeek() {

Diff Legend

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