# | Line 940 | Line 940 | public class ForkJoinWorkerThread extend | |
---|---|---|
940 | UNSAFE.putOrderedObject(this, currentJoinOffset, joinMe); | |
941 | if (isTerminating()) // cancel if shutting down | |
942 | joinMe.cancelIgnoringExceptions(); | |
943 | < | else |
943 | > | else |
944 | pool.awaitJoin(joinMe, this, timed, nanos); | |
945 | UNSAFE.putOrderedObject(this, currentJoinOffset, prevJoin); | |
946 | } |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |