# | Line 331 | Line 331 | public class ForkJoinWorkerThread extend | |
---|---|---|
331 | */ | |
332 | protected void onStart() { | |
333 | queue = new ForkJoinTask<?>[INITIAL_QUEUE_CAPACITY]; | |
334 | < | int r = pool.workerSeedGenerator.nextInt(); |
334 | > | int r = ForkJoinPool.workerSeedGenerator.nextInt(); |
335 | seed = (r == 0) ? 1 : r; // must be nonzero | |
336 | } | |
337 | ||
# | Line 955 | Line 955 | public class ForkJoinWorkerThread extend | |
955 | int s; | |
956 | try { | |
957 | UNSAFE = getUnsafe(); | |
958 | < | Class a = ForkJoinTask[].class; |
958 | > | Class<?> a = ForkJoinTask[].class; |
959 | ABASE = UNSAFE.arrayBaseOffset(a); | |
960 | s = UNSAFE.arrayIndexScale(a); | |
961 | } catch (Exception e) { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |