[ViewVC] Diff of: jsr166/jsr166/src/test/tck/BlockingQueueTest.java

Comparing jsr166/src/test/tck/BlockingQueueTest.java (file contents):
Revision 1.7 by jsr166, Fri May 27 19:32:04 2011 UTC vs.
Revision 1.22 by jsr166, Fri Jun 22 00:04:58 2018 UTC

+ * Pat Fisher, Mike Judd.
+ */
-–
+import junit.framework.*;
-–
+import java.util.*;
-–
+import java.util.concurrent.*;
+import static java.util.concurrent.TimeUnit.MILLISECONDS;
-+
+import java.util.ArrayList;
-+
+import java.util.Arrays;
-+
+import java.util.Collection;
-+
+import java.util.Queue;
-+
+import java.util.concurrent.BlockingQueue;
-+
+import java.util.concurrent.CountDownLatch;
-+
-+
+import junit.framework.Test;
-+
+import junit.framework.TestSuite;
-+
+/**
-<
+ * Contains tests generally applicable to BlockingQueue implementations.
->
+ * Contains "contract" tests applicable to all BlockingQueue implementations.
+ */
+public abstract class BlockingQueueTest extends JSR166TestCase {
+    /*
+        return new TestSuite(this.getClass());
-+
+    //----------------------------------------------------------------
-+
+    // Configuration methods
-+
+    //----------------------------------------------------------------
-+
+    /** Returns an empty instance of the implementation class. */
+    protected abstract BlockingQueue emptyCollection();
+    /**
-+
+     * Returns an element suitable for insertion in the collection.
-+
+     * Override for collections with unusual element types.
-+
+     */
-+
+    protected Object makeElement(int i) {
-+
+        return Integer.valueOf(i);
-+
+    }
-+
-+
+    //----------------------------------------------------------------
-+
+    // Tests
-+
+    //----------------------------------------------------------------
-+
-+
+    /**
-+
+     * offer(null) throws NullPointerException
-+
+     */
-+
+    public void testOfferNull() {
-+
+        final Queue q = emptyCollection();
-+
+        try {
-+
+            q.offer(null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * add(null) throws NullPointerException
-+
+     */
-+
+    public void testAddNull() {
-+
+        final Collection q = emptyCollection();
-+
+        try {
-+
+            q.add(null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * timed offer(null) throws NullPointerException
-+
+     */
-+
+    public void testTimedOfferNull() throws InterruptedException {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        long startTime = System.nanoTime();
-+
+        try {
-+
+            q.offer(null, LONG_DELAY_MS, MILLISECONDS);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
-+
+    }
-+
-+
+    /**
-+
+     * put(null) throws NullPointerException
-+
+     */
-+
+    public void testPutNull() throws InterruptedException {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        try {
-+
+            q.put(null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * addAll(null) throws NullPointerException
-+
+     */
-+
+    public void testAddAllNull() throws InterruptedException {
-+
+        final Collection q = emptyCollection();
-+
+        try {
-+
+            q.addAll(null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * addAll of a collection with null elements throws NullPointerException
-+
+     */
-+
+    public void testAddAllNullElements() {
-+
+        final Collection q = emptyCollection();
-+
+        final Collection<Integer> elements = Arrays.asList(new Integer[SIZE]);
-+
+        try {
-+
+            q.addAll(elements);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * toArray(null) throws NullPointerException
-+
+     */
-+
+    public void testToArray_NullArray() {
-+
+        final Collection q = emptyCollection();
-+
+        try {
-+
+            q.toArray((Object[])null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * drainTo(null) throws NullPointerException
-+
+     */
-+
+    public void testDrainToNull() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        try {
-+
+            q.drainTo(null);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * drainTo(this) throws IllegalArgumentException
-+
+     */
-+
+    public void testDrainToSelf() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        try {
-+
+            q.drainTo(q);
-+
+            shouldThrow();
-+
+        } catch (IllegalArgumentException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * drainTo(null, n) throws NullPointerException
-+
+     */
-+
+    public void testDrainToNullN() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        try {
-+
+            q.drainTo(null, 0);
-+
+            shouldThrow();
-+
+        } catch (NullPointerException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * drainTo(this, n) throws IllegalArgumentException
-+
+     */
-+
+    public void testDrainToSelfN() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        try {
-+
+            q.drainTo(q, 0);
-+
+            shouldThrow();
-+
+        } catch (IllegalArgumentException success) {}
-+
+    }
-+
-+
+    /**
-+
+     * drainTo(c, n) returns 0 and does nothing when n <= 0
-+
+     */
-+
+    public void testDrainToNonPositiveMaxElements() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        final int[] ns = { 0, -1, -42, Integer.MIN_VALUE };
-+
+        final ArrayList sink = new ArrayList();
-+
+        for (int n : ns) {
-+
+            assertEquals(0, q.drainTo(sink, n));
-+
+            assertTrue(sink.isEmpty());
-+
+        }
-+
+        if (q.remainingCapacity() > 0) {
-+
+            // Not SynchronousQueue, that is
-+
+            Object one = makeElement(1);
-+
+            q.add(one);
-+
+            for (int n : ns)
-+
+                assertEquals(0, q.drainTo(sink, n));
-+
+            assertEquals(1, q.size());
-+
+            assertSame(one, q.poll());
-+
+            assertTrue(sink.isEmpty());
-+
+        }
-+
+    }
-+
-+
+    /**
+     * timed poll before a delayed offer times out; after offer succeeds;
+     * on interruption throws
+     */
+    public void testTimedPollWithOffer() throws InterruptedException {
+        final BlockingQueue q = emptyCollection();
+        final CheckedBarrier barrier = new CheckedBarrier(2);
-+
+        final Object zero = makeElement(0);
+        Thread t = newStartedThread(new CheckedRunnable() {
+            public void realRun() throws InterruptedException {
+                long startTime = System.nanoTime();
+                    shouldThrow();
+                } catch (InterruptedException success) {}
+                assertFalse(Thread.interrupted());
-+
-+
+                assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
+            }});
+        barrier.await();
+        assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
+        barrier.await();
-<
+        assertThreadStaysAlive(t);
->
+        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
+        t.interrupt();
+        awaitTermination(t);
+            }});
+        await(threadStarted);
-<
+        assertThreadStaysAlive(t);
->
+        assertThreadBlocks(t, Thread.State.WAITING);
+        t.interrupt();
+        awaitTermination(t);
+            }});
+        await(threadStarted);
-<
+        assertThreadStaysAlive(t);
->
+        assertThreadBlocks(t, Thread.State.TIMED_WAITING);
+        t.interrupt();
+        awaitTermination(t);
+        awaitTermination(t);
-+
+    /**
-+
+     * remove(x) removes x and returns true if present
-+
+     * TODO: move to superclass CollectionTest.java
-+
+     */
-+
+    public void testRemoveElement() {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        final int size = Math.min(q.remainingCapacity(), SIZE);
-+
+        final Object[] elts = new Object[size];
-+
+        assertFalse(q.contains(makeElement(99)));
-+
+        assertFalse(q.remove(makeElement(99)));
-+
+        checkEmpty(q);
-+
+        for (int i = 0; i < size; i++)
-+
+            q.add(elts[i] = makeElement(i));
-+
+        for (int i = 1; i < size; i += 2) {
-+
+            for (int pass = 0; pass < 2; pass++) {
-+
+                assertEquals((pass == 0), q.contains(elts[i]));
-+
+                assertEquals((pass == 0), q.remove(elts[i]));
-+
+                assertFalse(q.contains(elts[i]));
-+
+                assertTrue(q.contains(elts[i - 1]));
-+
+                if (i < size - 1)
-+
+                    assertTrue(q.contains(elts[i + 1]));
-+
+            }
-+
+        }
-+
+        if (size > 0)
-+
+            assertTrue(q.contains(elts[0]));
-+
+        for (int i = size - 2; i >= 0; i -= 2) {
-+
+            assertTrue(q.contains(elts[i]));
-+
+            assertFalse(q.contains(elts[i + 1]));
-+
+            assertTrue(q.remove(elts[i]));
-+
+            assertFalse(q.contains(elts[i]));
-+
+            assertFalse(q.remove(elts[i + 1]));
-+
+            assertFalse(q.contains(elts[i + 1]));
-+
+        }
-+
+        checkEmpty(q);
-+
+    }
-+
+    /** For debugging. */
+    public void XXXXtestFails() {
+        fail(emptyCollection().getClass().toString());

Diff Legend

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

Comparing jsr166/src/test/tck/BlockingQueueTest.java (file contents): Revision 1.7 by jsr166, Fri May 27 19:32:04 2011 UTC vs. Revision 1.22 by jsr166, Fri Jun 22 00:04:58 2018 UTC

Diff Legend

Comparing jsr166/src/test/tck/BlockingQueueTest.java (file contents):
Revision 1.7 by jsr166, Fri May 27 19:32:04 2011 UTC vs.
Revision 1.22 by jsr166, Fri Jun 22 00:04:58 2018 UTC