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