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

Comparing jsr166/src/test/tck/ForkJoinTask8Test.java (file contents):
Revision 1.22 by dl, Thu Oct 8 23:02:21 2015 UTC vs.
Revision 1.25 by dl, Sun Oct 11 19:53:59 2015 UTC

# Line 243 | Line 243 | public class ForkJoinTask8Test extends J
243              super.completeExceptionally(ex);
244          }
245  
246 +        public boolean cancel(boolean mayInterruptIfRunning) {
247 +            if (super.cancel(mayInterruptIfRunning)) {
248 +                completeExceptionally(new FJException());
249 +                return true;
250 +            }
251 +            return false;
252 +        }
253 +
254          public final void complete() {
255              BinaryAsyncAction a = this;
256              for (;;) {
# Line 265 | Line 273 | public class ForkJoinTask8Test extends J
273          }
274  
275          public final void completeExceptionally(Throwable ex) {
276 <            BinaryAsyncAction a = this;
269 <            while (!a.isCompletedAbnormally()) {
276 >            for (BinaryAsyncAction a = this;;) {
277                  a.completeThisExceptionally(ex);
278                  BinaryAsyncAction s = a.sibling;
279 <                if (s != null)
280 <                    s.cancel(false);
281 <                if (!a.onException() || (a = a.parent) == null)
279 >                if (s != null && !s.isDone())
280 >                    s.completeExceptionally(ex);
281 >                if ((a = a.parent) == null)
282                      break;
283              }
284          }
# Line 303 | Line 310 | public class ForkJoinTask8Test extends J
310              try {
311                  AsyncFib f = this;
312                  int n = f.number;
313 <                if (n > 1) {
314 <                    while (n > 1) {
315 <                        AsyncFib p = f;
316 <                        AsyncFib r = new AsyncFib(n - 2);
317 <                        f = new AsyncFib(--n);
318 <                        p.linkSubtasks(r, f);
312 <                        r.fork();
313 <                    }
314 <                    f.number = n;
313 >                while (n > 1) {
314 >                    AsyncFib p = f;
315 >                    AsyncFib r = new AsyncFib(n - 2);
316 >                    f = new AsyncFib(--n);
317 >                    p.linkSubtasks(r, f);
318 >                    r.fork();
319                  }
320                  f.complete();
321              }
322              catch (Throwable ex) {
323                  compareAndSetForkJoinTaskTag(INITIAL_STATE, EXCEPTION_STATE);
320 –                throw new Error(ex);
324              }
325 +            if (getForkJoinTaskTag() == EXCEPTION_STATE)
326 +                throw new FJException();
327              return false;
328          }
329  
# Line 340 | Line 345 | public class ForkJoinTask8Test extends J
345          }
346  
347          public final boolean exec() {
348 <            FailingAsyncFib f = this;
349 <            int n = f.number;
350 <            if (n > 1) {
348 >            try {
349 >                FailingAsyncFib f = this;
350 >                int n = f.number;
351                  while (n > 1) {
352                      FailingAsyncFib p = f;
353                      FailingAsyncFib r = new FailingAsyncFib(n - 2);
# Line 350 | Line 355 | public class ForkJoinTask8Test extends J
355                      p.linkSubtasks(r, f);
356                      r.fork();
357                  }
358 <                f.number = n;
358 >                f.complete();
359 >            }
360 >            catch (Throwable ex) {
361 >                compareAndSetForkJoinTaskTag(INITIAL_STATE, EXCEPTION_STATE);
362              }
363 <            f.complete();
363 >            if (getForkJoinTaskTag() == EXCEPTION_STATE)
364 >                throw new FJException();
365              return false;
366          }
367  

Diff Legend

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