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

Comparing jsr166/src/test/tck/RecursiveActionTest.java (file contents):
Revision 1.21 by jsr166, Sun Nov 21 19:06:53 2010 UTC vs.
Revision 1.28 by jsr166, Wed Dec 1 22:37:51 2010 UTC

+import junit.framework.*;
+import java.util.concurrent.CancellationException;
-+
+import java.util.concurrent.SynchronousQueue;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ForkJoinPool;
-+
+import java.util.concurrent.ForkJoinTask;
+import java.util.concurrent.ForkJoinWorkerThread;
+import java.util.concurrent.RecursiveAction;
+import java.util.concurrent.TimeUnit;
+        assertNull(a.getException());
+        assertNull(a.getRawResult());
-<
+        if (! (Thread.currentThread() instanceof ForkJoinWorkerThread)) {
->
+        if (! ForkJoinTask.inForkJoinPool()) {
+            Thread.currentThread().interrupt();
+            try {
+                a.get();
+        assertNull(a.getException());
+        assertNull(a.getRawResult());
+        assertNull(a.join());
-+
+        assertFalse(a.cancel(false));
-+
+        assertFalse(a.cancel(true));
+        try {
+            assertNull(a.get());
+        } catch (Throwable fail) { threadUnexpectedException(fail); }
+        assertTrue(a.isCompletedAbnormally());
+        assertSame(t, a.getException());
+        assertNull(a.getRawResult());
-+
+        assertFalse(a.cancel(false));
-+
+        assertFalse(a.cancel(true));
+        try {
+            a.join();
+    /**
-+
+     * join/quietlyJoin of a forked task succeeds in the presence of interrupts
-+
+     */
-+
+    public void testJoinIgnoresInterrupts() {
-+
+        RecursiveAction a = new CheckedRecursiveAction() {
-+
+            public void realCompute() {
-+
+                FibAction f = new FibAction(8);
-+
+                final Thread myself = Thread.currentThread();
-+
-+
+                // test join()
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                assertNull(f.join());
-+
+                Thread.interrupted();
-+
+                assertEquals(21, f.result);
-+
+                checkCompletedNormally(f);
-+
-+
+                f.reinitialize();
-+
+                f.cancel(true);
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                try {
-+
+                    f.join();
-+
+                    shouldThrow();
-+
+                } catch (CancellationException success) {
-+
+                    Thread.interrupted();
-+
+                    checkCancelled(f);
-+
+                }
-+
-+
+                f.reinitialize();
-+
+                f.completeExceptionally(new FJException());
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                try {
-+
+                    f.join();
-+
+                    shouldThrow();
-+
+                } catch (FJException success) {
-+
+                    Thread.interrupted();
-+
+                    checkCompletedAbnormally(f, success);
-+
+                }
-+
-+
+                // test quietlyJoin()
-+
+                f.reinitialize();
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                Thread.interrupted();
-+
+                assertEquals(21, f.result);
-+
+                checkCompletedNormally(f);
-+
-+
+                f.reinitialize();
-+
+                f.cancel(true);
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                Thread.interrupted();
-+
+                checkCancelled(f);
-+
-+
+                f.reinitialize();
-+
+                f.completeExceptionally(new FJException());
-+
+                assertSame(f, f.fork());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                Thread.interrupted();
-+
+                checkCompletedAbnormally(f, f.getException());
-+
+            }};
-+
+        testInvokeOnPool(mainPool(), a);
-+
+        a.reinitialize();
-+
+        testInvokeOnPool(singletonPool(), a);
-+
+    }
-+
-+
+    /**
-+
+     * join/quietlyJoin of a forked task when not in ForkJoinPool
-+
+     * succeeds in the presence of interrupts
-+
+     */
-+
+    public void testJoinIgnoresInterruptsOutsideForkJoinPool() {
-+
+        final SynchronousQueue<FibAction[]> sq =
-+
+            new SynchronousQueue<FibAction[]>();
-+
+        RecursiveAction a = new CheckedRecursiveAction() {
-+
+            public void realCompute() throws InterruptedException {
-+
+                FibAction[] fibActions = new FibAction[6];
-+
+                for (int i = 0; i < fibActions.length; i++)
-+
+                    fibActions[i] = new FibAction(8);
-+
-+
+                fibActions[1].cancel(false);
-+
+                fibActions[2].completeExceptionally(new FJException());
-+
+                fibActions[4].cancel(true);
-+
+                fibActions[5].completeExceptionally(new FJException());
-+
-+
+                for (int i = 0; i < fibActions.length; i++)
-+
+                    fibActions[i].fork();
-+
-+
+                sq.put(fibActions);
-+
-+
+                helpQuiesce();
-+
+            }};
-+
-+
+        Runnable r = new CheckedRunnable() {
-+
+            public void realRun() throws InterruptedException {
-+
+                FibAction[] fibActions = sq.take();
-+
+                FibAction f;
-+
+                final Thread myself = Thread.currentThread();
-+
-+
+                // test join() ------------
-+
-+
+                f = fibActions[0];
-+
+                assertFalse(ForkJoinTask.inForkJoinPool());
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                assertNull(f.join());
-+
+                assertTrue(Thread.interrupted());
-+
+                assertEquals(21, f.result);
-+
+                checkCompletedNormally(f);
-+
-+
+                f = fibActions[1];
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                try {
-+
+                    f.join();
-+
+                    shouldThrow();
-+
+                } catch (CancellationException success) {
-+
+                    assertTrue(Thread.interrupted());
-+
+                    checkCancelled(f);
-+
+                }
-+
-+
+                f = fibActions[2];
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                try {
-+
+                    f.join();
-+
+                    shouldThrow();
-+
+                } catch (FJException success) {
-+
+                    assertTrue(Thread.interrupted());
-+
+                    checkCompletedAbnormally(f, success);
-+
+                }
-+
-+
+                // test quietlyJoin() ---------
-+
-+
+                f = fibActions[3];
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                assertTrue(Thread.interrupted());
-+
+                assertEquals(21, f.result);
-+
+                checkCompletedNormally(f);
-+
-+
+                f = fibActions[4];
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                assertTrue(Thread.interrupted());
-+
+                checkCancelled(f);
-+
-+
+                f = fibActions[5];
-+
+                myself.interrupt();
-+
+                assertTrue(myself.isInterrupted());
-+
+                f.quietlyJoin();
-+
+                assertTrue(Thread.interrupted());
-+
+                assertTrue(f.getException() instanceof FJException);
-+
+                checkCompletedAbnormally(f, f.getException());
-+
+            }};
-+
-+
+        Thread t;
-+
-+
+        t = newStartedThread(r);
-+
+        testInvokeOnPool(mainPool(), a);
-+
+        awaitTermination(t, LONG_DELAY_MS);
-+
-+
+        a.reinitialize();
-+
+        t = newStartedThread(r);
-+
+        testInvokeOnPool(singletonPool(), a);
-+
+        awaitTermination(t, LONG_DELAY_MS);
-+
+    }
-+
-+
+    /**
+     * get of a forked task returns when task completes
+     */
+    public void testForkGet() {
+        RecursiveAction a = new CheckedRecursiveAction() {
+            public void realCompute() {
+                ForkJoinWorkerThread w =
-<
+                    (ForkJoinWorkerThread)(Thread.currentThread());
->
+                    (ForkJoinWorkerThread) Thread.currentThread();
+                assertTrue(w.getPoolIndex() >= 0);
+                assertTrue(w.getPoolIndex() < mainPool.getPoolSize());
+            }};
+        RecursiveAction a = new CheckedRecursiveAction() {
+            public void realCompute() {
+                setRawResult(null);
-+
+                assertNull(getRawResult());
+            }};
+        assertNull(a.invoke());

Diff Legend

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

Comparing jsr166/src/test/tck/RecursiveActionTest.java (file contents): Revision 1.21 by jsr166, Sun Nov 21 19:06:53 2010 UTC vs. Revision 1.28 by jsr166, Wed Dec 1 22:37:51 2010 UTC

Diff Legend

Comparing jsr166/src/test/tck/RecursiveActionTest.java (file contents):
Revision 1.21 by jsr166, Sun Nov 21 19:06:53 2010 UTC vs.
Revision 1.28 by jsr166, Wed Dec 1 22:37:51 2010 UTC