# | 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) { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |