ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/ForkJoinTask.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/ForkJoinTask.java (file contents):
Revision 1.17 by dl, Wed Aug 11 18:45:45 2010 UTC vs.
Revision 1.18 by dl, Wed Aug 11 19:44:51 2010 UTC

# Line 641 | Line 641 | public abstract class ForkJoinTask<V> im
641           */
642          boolean interrupted = false;
643          boolean dec = false; // true if pool count decremented
644 +        long nanos = unit.toNanos(timeout);
645          for (;;) {
646              if (Thread.interrupted() && pool == null) {
647                  interrupted = true;
# Line 651 | Line 652 | public abstract class ForkJoinTask<V> im
652                  break;
653              if (UNSAFE.compareAndSwapInt(this, statusOffset, s, SIGNAL)) {
654                  long startTime = System.nanoTime();
654                long nanos = unit.toNanos(timeout);
655                  long nt; // wait time
656                  while (status >= 0 &&
657                         (nt = nanos - (System.nanoTime() - startTime)) > 0) {

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines