Searched refs:ForEachOrderedTask (Results 1 – 1 of 1) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | ForEachOps.java | 158 new ForEachOrderedTask<>(helper, spliterator, this).invoke(); in evaluateParallel()
320 static final class ForEachOrderedTask<S, T> extends CountedCompleter<Void> { class in ForEachOps
368 … private final ConcurrentHashMap<ForEachOrderedTask<S, T>, ForEachOrderedTask<S, T>> completionMap;
370 private final ForEachOrderedTask<S, T> leftPredecessor;
373 protected ForEachOrderedTask(PipelineHelper<T> helper, in ForEachOrderedTask() method in ForEachOps.ForEachOrderedTask
386 ForEachOrderedTask(ForEachOrderedTask<S, T> parent, in ForEachOrderedTask() method in ForEachOps.ForEachOrderedTask
388 ForEachOrderedTask<S, T> leftPredecessor) { in ForEachOrderedTask()
403 private static <S, T> void doCompute(ForEachOrderedTask<S, T> task) { in doCompute()
409 ForEachOrderedTask<S, T> leftChild = in doCompute()
410 new ForEachOrderedTask<>(task, leftSplit, task.leftPredecessor); in doCompute()
[all …]
|