7 |
|
package java.util; |
8 |
|
|
9 |
|
import java.util.concurrent.CountedCompleter; |
10 |
– |
import java.util.concurrent.ForkJoinPool; |
10 |
|
import java.util.function.BinaryOperator; |
11 |
|
import java.util.function.DoubleBinaryOperator; |
12 |
|
import java.util.function.IntBinaryOperator; |
72 |
|
/** The smallest subtask array partition size to use as threshold */ |
73 |
|
static final int MIN_PARTITION = 16; |
74 |
|
|
75 |
< |
static final class CumulateTask<T> extends CountedCompleter<Void> { |
75 |
> |
private static final class CumulateTask<T> |
76 |
> |
extends CountedCompleter<Void> { |
77 |
|
final T[] array; |
78 |
|
final BinaryOperator<T> function; |
79 |
|
CumulateTask<T> left, right; |
211 |
|
private static final long serialVersionUID = 5293554502939613543L; |
212 |
|
} |
213 |
|
|
214 |
< |
static final class LongCumulateTask extends CountedCompleter<Void> { |
214 |
> |
private static final class LongCumulateTask |
215 |
> |
extends CountedCompleter<Void> { |
216 |
|
final long[] array; |
217 |
|
final LongBinaryOperator function; |
218 |
|
LongCumulateTask left, right; |
348 |
|
private static final long serialVersionUID = -5074099945909284273L; |
349 |
|
} |
350 |
|
|
351 |
< |
static final class DoubleCumulateTask extends CountedCompleter<Void> { |
351 |
> |
private static final class DoubleCumulateTask |
352 |
> |
extends CountedCompleter<Void> { |
353 |
|
final double[] array; |
354 |
|
final DoubleBinaryOperator function; |
355 |
|
DoubleCumulateTask left, right; |
485 |
|
private static final long serialVersionUID = -586947823794232033L; |
486 |
|
} |
487 |
|
|
488 |
< |
static final class IntCumulateTask extends CountedCompleter<Void> { |
488 |
> |
private static final class IntCumulateTask |
489 |
> |
extends CountedCompleter<Void> { |
490 |
|
final int[] array; |
491 |
|
final IntBinaryOperator function; |
492 |
|
IntCumulateTask left, right; |