util/stream/Node.java

8  * particular file as subject to the "Classpath" exception as provided
18  * 2 along with this work; if not, write to the Free Software Foundation,
49  * mediates access to one or more existing (effectively immutable) data
52  * corresponds to the computation tree that produced the elements that are
54  * framework is largely to avoid copying data unnecessarily during parallel
76      * @param consumer a {@code Consumer} that is to be invoked with each
98      * @param i the index to the child node
101      *         than or equal to the number of child nodes
112      * @param from The (inclusive) starting offset of elements to include, must
114      * @param to The (exclusive) end offset of elements to include, must be
116      * @param generator A function to be used to create a new array, if needed,
120     default Node<T> truncate(long from, long to, IntFunction<T[]> generator) {
121         if (from == 0 && to == count())
124         long size = to - from;
128         if (to == count()) {
141      * reference to an internal array rather than a copy.  Since the returned
143      * {@code generator} function may be consulted to create the array if a new
144      * array needs to be created.
155      * given offset into the array.  It is the caller's responsibility to ensure
160      * @param array the array into which to copy the contents of this
190      * builds a flat node containing the elements that have been pushed to it.
245          * @param action a consumer that is to be invoked with each
256         T_NODE truncate(long from, long to, IntFunction<T[]> generator);
261          * @implSpec the default implementation invokes the generator to create
283          * reference to an internal array rather than a copy.  It is the callers
284          * responsibility to decide if either this node or the array is utilized
302          * responsibility to ensure there is sufficient room in the array.
304          * @param array the array into which to copy the contents of this
322          * @param consumer a {@code Consumer} that is to be invoked with each
324          *        {@code IntConsumer}, it is cast to {@code IntConsumer} so the
342          * @implSpec the default implementation invokes {@link #asPrimitiveArray()} to
345          * is recommended to invoke {@link #copyInto(Object, int)}.
359         default Node.OfInt truncate(long from, long to, IntFunction<Integer[]> generator) {
360             if (from == 0 && to == count())
362             long size = to - from;
367             if (to == count()) {
399          * @param consumer A {@code Consumer} that is to be invoked with each
401          *        {@code LongConsumer}, it is cast to {@code LongConsumer} so
420          * to obtain a long[] array then and copies the elements from that
422          * it is recommended to invoke {@link #copyInto(Object, int)}.
436         default Node.OfLong truncate(long from, long to, IntFunction<Long[]> generator) {
437             if (from == 0 && to == count())
439             long size = to - from;
444             if (to == count()) {
476          * @param consumer A {@code Consumer} that is to be invoked with each
478          *        {@code DoubleConsumer}, it is cast to {@code DoubleConsumer}
499          * to obtain a double[] array then and copies the elements from that
501          * and it is recommended to invoke {@link #copyInto(Object, int)}.
515         default Node.OfDouble truncate(long from, long to, IntFunction<Double[]> generator) {
516             if (from == 0 && to == count())
518             long size = to - from;
523             if (to == count()) {