Modifier and Type	Class and Description
private static class	SliceOps.SliceTask< Input element type to the stream pipeline P_IN, Output element type from the stream pipeline P_OUT> `ForkJoinTask` implementing slice computation.

Access	Constructor and Description
private	SliceOps()

Method Summary

Modifier and Type	Method and Description
private static long	Returns: the sliced size calcSize(long the current size size, long the number of elements to skip, assumed to be >= 0 skip, long the number of elements to limit, assumed to be >= 0, with a value of `Long.MAX_VALUE` if there is no limit limit) Calculates the sliced size given the current size, number of elements skip, and the number of elements to limit.
private static long	Returns: the slice fence. calcSliceFence(long the number of elements to skip, assumed to be >= 0 skip, long the number of elements to limit, assumed to be >= 0, with a value of `Long.MAX_VALUE` if there is no limit limit) Calculates the slice fence, which is one past the index of the slice range
private static int	flags(long limit)
public static DoubleStream	makeDouble(AbstractPipeline<?, Double, ?> A DoubleStream upstream, long The number of elements to skip. Must be >= 0. skip, long The maximum size of the resulting stream, or -1 if no limit is to be imposed limit) Appends a "slice" operation to the provided DoubleStream.
public static IntStream	makeInt(AbstractPipeline<?, Integer, ?> An IntStream upstream, long The number of elements to skip. Must be >= 0. skip, long The maximum size of the resulting stream, or -1 if no limit is to be imposed limit) Appends a "slice" operation to the provided IntStream.
public static LongStream	makeLong(AbstractPipeline<?, Long, ?> A LongStream upstream, long The number of elements to skip. Must be >= 0. skip, long The maximum size of the resulting stream, or -1 if no limit is to be imposed limit) Appends a "slice" operation to the provided LongStream.
public static < the type of both input and output elements T> Stream<T>	makeRef(AbstractPipeline<?, T, ?> a reference stream with element type T upstream, long the number of elements to skip. Must be >= 0. skip, long the maximum size of the resulting stream, or -1 if no limit is to be imposed limit) Appends a "slice" operation to the provided stream.
private static <P_IN> Spliterator<P_IN>	sliceSpliterator(StreamShape shape, Spliterator<P_IN> s, long skip, long limit) Creates a slice spliterator given a stream shape governing the spliterator type.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

SliceOps	back to summary
private SliceOps()

Method Detail

calcSize back to summary

calcSize	back to summary
private static long calcSize(long size, long skip, long limit) Calculates the sliced size given the current size, number of elements skip, and the number of elements to limit. Parameters size:long the current size skip:long the number of elements to skip, assumed to be >= 0 limit:long the number of elements to limit, assumed to be >= 0, with a value of `Long.MAX_VALUE` if there is no limit Returns:long the sliced size

private static long calcSize(long size, long skip, long limit)

Calculates the sliced size given the current size, number of elements skip, and the number of elements to limit.

Parameters

size:long: the current size
skip:long: the number of elements to skip, assumed to be >= 0
limit:long: the number of elements to limit, assumed to be >= 0, with a value of Long.MAX_VALUE if there is no limit

Returns:long

the sliced size

calcSliceFence back to summary

calcSliceFence	back to summary
private static long calcSliceFence(long skip, long limit) Calculates the slice fence, which is one past the index of the slice range Parameters skip:long the number of elements to skip, assumed to be >= 0 limit:long the number of elements to limit, assumed to be >= 0, with a value of `Long.MAX_VALUE` if there is no limit Returns:long the slice fence.

private static long calcSliceFence(long skip, long limit)

Calculates the slice fence, which is one past the index of the slice range

Parameters

skip:long: the number of elements to skip, assumed to be >= 0
limit:long: the number of elements to limit, assumed to be >= 0, with a value of Long.MAX_VALUE if there is no limit

Returns:long

the slice fence.

flags	back to summary
private static int flags(long limit)

makeDouble	back to summary
public static DoubleStream makeDouble(AbstractPipeline<?, Double, ?> upstream, long skip, long limit) Appends a "slice" operation to the provided DoubleStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit. Parameters upstream:AbstractPipeline<?, Double, ?> A DoubleStream skip:long The number of elements to skip. Must be >= 0. limit:long The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeDouble

back to summary

public static DoubleStream makeDouble(AbstractPipeline<?, Double, ?> upstream, long skip, long limit)

Appends a "slice" operation to the provided DoubleStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit.

Parameters

upstream:AbstractPipeline<?, Double, ?>: A DoubleStream
skip:long: The number of elements to skip. Must be >= 0.
limit:long: The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeInt	back to summary
public static IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream, long skip, long limit) Appends a "slice" operation to the provided IntStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit. Parameters upstream:AbstractPipeline<?, Integer, ?> An IntStream skip:long The number of elements to skip. Must be >= 0. limit:long The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeInt

back to summary

public static IntStream makeInt(AbstractPipeline<?, Integer, ?> upstream, long skip, long limit)

Appends a "slice" operation to the provided IntStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit.

Parameters

upstream:AbstractPipeline<?, Integer, ?>: An IntStream
skip:long: The number of elements to skip. Must be >= 0.
limit:long: The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeLong	back to summary
public static LongStream makeLong(AbstractPipeline<?, Long, ?> upstream, long skip, long limit) Appends a "slice" operation to the provided LongStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit. Parameters upstream:AbstractPipeline<?, Long, ?> A LongStream skip:long The number of elements to skip. Must be >= 0. limit:long The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeLong

back to summary

public static LongStream makeLong(AbstractPipeline<?, Long, ?> upstream, long skip, long limit)

Appends a "slice" operation to the provided LongStream. The slice operation may be may be skip-only, limit-only, or skip-and-limit.

Parameters

upstream:AbstractPipeline<?, Long, ?>: A LongStream
skip:long: The number of elements to skip. Must be >= 0.
limit:long: The maximum size of the resulting stream, or -1 if no limit is to be imposed

makeRef	back to summary
public static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, long skip, long limit) Appends a "slice" operation to the provided stream. The slice operation may be may be skip-only, limit-only, or skip-and-limit. Parameters <T> the type of both input and output elements upstream:AbstractPipeline<?, T, ?> a reference stream with element type T skip:long the number of elements to skip. Must be >= 0. limit:long the maximum size of the resulting stream, or -1 if no limit is to be imposed

makeRef

back to summary

public static <T> Stream<T> makeRef(AbstractPipeline<?, T, ?> upstream, long skip, long limit)

Appends a "slice" operation to the provided stream. The slice operation may be may be skip-only, limit-only, or skip-and-limit.

Parameters

<T>: the type of both input and output elements
upstream:AbstractPipeline<?, T, ?>: a reference stream with element type T
skip:long: the number of elements to skip. Must be >= 0.
limit:long: the maximum size of the resulting stream, or -1 if no limit is to be imposed

sliceSpliterator	back to summary
private static <P_IN> Spliterator<P_IN> sliceSpliterator(StreamShape shape, Spliterator<P_IN> s, long skip, long limit) Creates a slice spliterator given a stream shape governing the spliterator type. Requires that the underlying Spliterator be SUBSIZED.

java.util.stream back to summary

private final Class SliceOps.SliceTask<P_IN, P_OUT>

Class Inheritance

extends AbstractShortCircuitTask<P_IN, P_OUT, Node<P_OUT>, SliceOps.SliceTask<P_IN, P_OUT>>

java.lang.Object
java.util.concurrent.ForkJoinTask
java.util.concurrent.CountedCompleter
java.util.stream.AbstractTask
java.util.stream.AbstractShortCircuitTask
java.util.stream.SliceOps.SliceTask

Annotations

@SuppressWarnings:serial

Type Parameters

<P_IN>: Input element type to the stream pipeline
<P_OUT>: Output element type from the stream pipeline

ForkJoinTask implementing slice computation.

Field Summary

Modifier and Type	Field and Description
private volatile boolean	completed
private final IntFunction<P_OUT[]>	generator
private final AbstractPipeline<P_OUT, P_OUT, ?>	op
private final long	targetOffset
private final long	targetSize Hides java.util.stream.AbstractTask.targetSize.
private long	thisNodeSize

Inherited from java.util.stream.AbstractShortCircuitTask:: canceled sharedResult

Constructor Summary

Access	Constructor and Description
pack-priv	SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op, PipelineHelper<P_OUT> helper, Spliterator<P_IN> spliterator, IntFunction<P_OUT[]> generator, long offset, long size)
pack-priv	SliceTask(SliceOps.SliceTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator)

Method Summary

Modifier and Type	Method and Description
protected void	cancel() Overrides java.util.stream.AbstractShortCircuitTask.cancel. Mark this task as canceled
private long	Returns: the number of completed elements completedSize(long the target size target) Compute the number of completed elements in this node.
protected final Node<P_OUT>	doLeaf() Implements abstract java.util.stream.AbstractTask.doLeaf. Computes the result associated with a leaf node.
private Node<P_OUT>	doTruncate(Node<P_OUT> input)
protected final Node<P_OUT>	getEmptyResult() Implements abstract java.util.stream.AbstractShortCircuitTask.getEmptyResult. Returns the value indicating the computation completed with no task finding a short-circuitable result.
private boolean	Returns: true if the number of elements is greater than or equal to the target size, otherwise false. isLeftCompleted(long the target size target) Determine if the number of completed elements in this node and nodes to the left of this node is greater than or equal to the target size.
protected SliceOps.SliceTask<P_IN, P_OUT>	makeChild(Spliterator<P_IN> spliterator) Implements abstract java.util.stream.AbstractTask.makeChild. Constructs a new node of type T whose parent is the receiver; must call the AbstractTask(T, Spliterator) constructor with the receiver and the provided Spliterator.
public final void	onCompletion(CountedCompleter<?> caller) Overrides java.util.stream.AbstractTask.onCompletion. Performs an action when method `tryComplete` is invoked and the pending count is zero, or when the unconditional method `complete` is invoked.

Inherited from java.util.stream.AbstractShortCircuitTask:: cancelLaterNodes compute getLocalResult getRawResult setLocalResult shortCircuit taskCanceled

Field Detail

completed	back to summary
private volatile boolean completed

generator	back to summary
private final IntFunction<P_OUT[]> generator

op	back to summary
private final AbstractPipeline<P_OUT, P_OUT, ?> op

targetOffset	back to summary
private final long targetOffset

targetSize	back to summary
private final long targetSize Hides java.util.stream.AbstractTask.targetSize.

thisNodeSize	back to summary
private long thisNodeSize

Constructor Detail

SliceTask	back to summary
pack-priv SliceTask(AbstractPipeline<P_OUT, P_OUT, ?> op, PipelineHelper<P_OUT> helper, Spliterator<P_IN> spliterator, IntFunction<P_OUT[]> generator, long offset, long size)

SliceTask	back to summary
pack-priv SliceTask(SliceOps.SliceTask<P_IN, P_OUT> parent, Spliterator<P_IN> spliterator)

Method Detail

cancel	back to summary
protected void cancel() Overrides java.util.stream.AbstractShortCircuitTask.cancel. Doc from java.util.stream.AbstractShortCircuitTask.cancel. Mark this task as canceled Annotations @Override

cancel

back to summary

protected void cancel()

Overrides java.util.stream.AbstractShortCircuitTask.cancel.

Doc from java.util.stream.AbstractShortCircuitTask.cancel.

Mark this task as canceled

Annotations

@Override

completedSize	back to summary
private long completedSize(long target) Compute the number of completed elements in this node. Computation terminates if all nodes have been processed or the number of completed elements is greater than or equal to the target size. Parameters target:long the target size Returns:long the number of completed elements

completedSize

back to summary

private long completedSize(long target)

Compute the number of completed elements in this node.

Computation terminates if all nodes have been processed or the number of completed elements is greater than or equal to the target size.

Parameters

target:long: the target size

Returns:long

the number of completed elements

doLeaf back to summary

doLeaf	back to summary
protected final Node<P_OUT> doLeaf() Implements abstract java.util.stream.AbstractTask.doLeaf. Doc from java.util.stream.AbstractTask.doLeaf. Computes the result associated with a leaf node. Will be called by `compute()` and the result passed to `setLocalResult()` Annotations @Override

protected final Node<P_OUT> doLeaf()

Implements abstract java.util.stream.AbstractTask.doLeaf.

Doc from java.util.stream.AbstractTask.doLeaf.

Computes the result associated with a leaf node. Will be called by compute() and the result passed to setLocalResult()

Annotations

@Override

doTruncate	back to summary
private Node<P_OUT> doTruncate(Node<P_OUT> input)

getEmptyResult back to summary

getEmptyResult	back to summary
protected final Node<P_OUT> getEmptyResult() Implements abstract java.util.stream.AbstractShortCircuitTask.getEmptyResult. Doc from java.util.stream.AbstractShortCircuitTask.getEmptyResult. Returns the value indicating the computation completed with no task finding a short-circuitable result. For example, for a "find" operation, this might be null or an empty `Optional`. Annotations @Override

protected final Node<P_OUT> getEmptyResult()

Implements abstract java.util.stream.AbstractShortCircuitTask.getEmptyResult.

Doc from java.util.stream.AbstractShortCircuitTask.getEmptyResult.

Returns the value indicating the computation completed with no task finding a short-circuitable result. For example, for a "find" operation, this might be null or an empty Optional.

Annotations

@Override

isLeftCompleted	back to summary
private boolean isLeftCompleted(long target) Determine if the number of completed elements in this node and nodes to the left of this node is greater than or equal to the target size. Parameters target:long the target size Returns:boolean true if the number of elements is greater than or equal to the target size, otherwise false.

isLeftCompleted

back to summary

private boolean isLeftCompleted(long target)

Determine if the number of completed elements in this node and nodes to the left of this node is greater than or equal to the target size.

Parameters

target:long: the target size

Returns:boolean

true if the number of elements is greater than or equal to the target size, otherwise false.

makeChild	back to summary
protected SliceOps.SliceTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator) Implements abstract java.util.stream.AbstractTask.makeChild. Doc from java.util.stream.AbstractTask.makeChild. Constructs a new node of type T whose parent is the receiver; must call the AbstractTask(T, Spliterator) constructor with the receiver and the provided Spliterator. Annotations @Override

makeChild

back to summary

protected SliceOps.SliceTask<P_IN, P_OUT> makeChild(Spliterator<P_IN> spliterator)

Implements abstract java.util.stream.AbstractTask.makeChild.

Doc from java.util.stream.AbstractTask.makeChild.

Constructs a new node of type T whose parent is the receiver; must call the AbstractTask(T, Spliterator) constructor with the receiver and the provided Spliterator.

Annotations

@Override

onCompletion back to summary

onCompletion	back to summary
public final void onCompletion(CountedCompleter<?> caller) Overrides java.util.stream.AbstractTask.onCompletion. Doc from java.util.stream.AbstractTask.onCompletion. Performs an action when method `tryComplete` is invoked and the pending count is zero, or when the unconditional method `complete` is invoked. By default, this method does nothing. You can distinguish cases by checking the identity of the given caller argument. If not equal to `this`, then it is typically a subtask that may contain results (and/or links to other results) to combine. Annotations @Override

public final void onCompletion(CountedCompleter<?> caller)

Overrides java.util.stream.AbstractTask.onCompletion.

Doc from java.util.stream.AbstractTask.onCompletion.

Performs an action when method tryComplete is invoked and the pending count is zero, or when the unconditional method complete is invoked. By default, this method does nothing. You can distinguish cases by checking the identity of the given caller argument. If not equal to this, then it is typically a subtask that may contain results (and/or links to other results) to combine.

Annotations

@Override

pack-priv final Class SliceOps

Nested and Inner Type Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private final Class SliceOps.SliceTask<P_IN, P_OUT>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail