Searched refs:ForEachOrderedTask (Results 1 – 1 of 1) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | ForEachOps.java | 157 new ForEachOrderedTask<>(helper, spliterator, this).invoke(); in evaluateParallel()
319 static final class ForEachOrderedTask<S, T> extends CountedCompleter<Void> { class in ForEachOps
367 … private final ConcurrentHashMap<ForEachOrderedTask<S, T>, ForEachOrderedTask<S, T>> completionMap;
369 private final ForEachOrderedTask<S, T> leftPredecessor;
372 protected ForEachOrderedTask(PipelineHelper<T> helper, in ForEachOrderedTask() method in ForEachOps.ForEachOrderedTask
385 ForEachOrderedTask(ForEachOrderedTask<S, T> parent, in ForEachOrderedTask() method in ForEachOps.ForEachOrderedTask
387 ForEachOrderedTask<S, T> leftPredecessor) { in ForEachOrderedTask()
402 private static <S, T> void doCompute(ForEachOrderedTask<S, T> task) { in doCompute()
408 ForEachOrderedTask<S, T> leftChild = in doCompute()
409 new ForEachOrderedTask<>(task, leftSplit, task.leftPredecessor); in doCompute()
[all …]
|