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

Comparing jsr166/src/test/tck/BlockingQueueTest.java (file contents):
Revision 1.1 by jsr166, Wed Oct 6 07:49:22 2010 UTC vs.
Revision 1.2 by jsr166, Thu Oct 28 17:57:26 2010 UTC

+        awaitTermination(t, MEDIUM_DELAY_MS);
-+
+    /**
-+
+     * take blocks interruptibly when empty
-+
+     */
-+
+    public void testTakeFromEmptyBlocksInterruptibly()
-+
+            throws InterruptedException {
-+
+        final BlockingQueue q = emptyCollection();
-+
+        final CountDownLatch threadStarted = new CountDownLatch(1);
-+
+        Thread t = newStartedThread(new CheckedRunnable() {
-+
+            public void realRun() {
-+
+                long t0 = System.nanoTime();
-+
+                threadStarted.countDown();
-+
+                try {
-+
+                    q.take();
-+
+                    shouldThrow();
-+
+                } catch (InterruptedException success) {}
-+
+                assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS);
-+
+            }});
-+
+        threadStarted.await();
-+
+        Thread.sleep(SHORT_DELAY_MS);
-+
+        assertTrue(t.isAlive());
-+
+        t.interrupt();
-+
+        awaitTermination(t, MEDIUM_DELAY_MS);
-+
+        assertFalse(t.isAlive());
-+
+    }
-+
+    /** For debugging. */
+    public void XXXXtestFails() {
+        fail(emptyCollection().getClass().toString());

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