| 292 |
|
* "terminate" status, cancels all unprocessed tasks, and wakes up |
| 293 |
|
* all waiting workers. Detecting whether termination should |
| 294 |
|
* commence after a non-abrupt shutdown() call requires more work |
| 295 |
< |
* and bookkeeping. We need consensus about quiesence (i.e., that |
| 295 |
> |
* and bookkeeping. We need consensus about quiescence (i.e., that |
| 296 |
|
* there is no more work) which is reflected in active counts so |
| 297 |
|
* long as there are no current blockers, as well as possible |
| 298 |
|
* re-evaluations during independent changes in blocking or |
| 2121 |
|
int s; |
| 2122 |
|
try { |
| 2123 |
|
UNSAFE = getUnsafe(); |
| 2124 |
< |
Class k = ForkJoinPool.class; |
| 2124 |
> |
Class<?> k = ForkJoinPool.class; |
| 2125 |
|
ctlOffset = UNSAFE.objectFieldOffset |
| 2126 |
|
(k.getDeclaredField("ctl")); |
| 2127 |
|
stealCountOffset = UNSAFE.objectFieldOffset |
| 2134 |
|
(k.getDeclaredField("scanGuard")); |
| 2135 |
|
nextWorkerNumberOffset = UNSAFE.objectFieldOffset |
| 2136 |
|
(k.getDeclaredField("nextWorkerNumber")); |
| 2137 |
< |
Class a = ForkJoinTask[].class; |
| 2137 |
> |
Class<?> a = ForkJoinTask[].class; |
| 2138 |
|
ABASE = UNSAFE.arrayBaseOffset(a); |
| 2139 |
|
s = UNSAFE.arrayIndexScale(a); |
| 2140 |
|
} catch (Exception e) { |
