src/extra166y/ParallelArrayWithDoubleMapping.java

/*
 * Written by Doug Lea with assistance from members of JCP JSR-166
 * Expert Group and released to the public domain, as explained at
 * http://creativecommons.org/publicdomain/zero/1.0/
 */

package extra166y;

import jsr166y.*;
import static extra166y.Ops.*;
import java.util.*;
import java.util.concurrent.atomic.*;

/**
 * A prefix view of ParallelArray that causes operations to apply
 * to mappings of elements, not to the elements themselves.
 * Instances of this class may be constructed only via prefix
 * methods of ParallelArray or its other prefix classes.
 */
public abstract class ParallelArrayWithDoubleMapping<T> extends AbstractParallelAnyArray.OPap<T> {
    ParallelArrayWithDoubleMapping
        (ForkJoinPool ex, int origin, int fence, T[] array) {
        super(ex, origin, fence, array);
    }

    /**
     * Applies the given procedure.
     * @param procedure the procedure
     */
    public void apply(DoubleProcedure procedure) {
        ex.invoke(new PAS.FJDApply(this, origin, fence, null, procedure));
    }

    /**
     * Returns reduction of mapped elements.
     * @param reducer the reducer
     * @param base the result for an empty array
     * @return reduction
     */
    public double reduce(DoubleReducer reducer, double base) {
        PAS.FJDReduce f = new PAS.FJDReduce
            (this, origin, fence, null, reducer, base);
        ex.invoke(f);
        return f.result;
    }

    /**
     * Returns the minimum element, or Double.MAX_VALUE if empty.
     * @return minimum element, or Double.MAX_VALUE if empty
     */
    public double min() {
        return reduce(CommonOps.naturalDoubleMinReducer(), Double.MAX_VALUE);
    }

    /**
     * Returns the minimum element, or Double.MAX_VALUE if empty.
     * @param comparator the comparator
     * @return minimum element, or Double.MAX_VALUE if empty
     */
    public double min(DoubleComparator comparator) {
        return reduce(CommonOps.doubleMinReducer(comparator), Double.MAX_VALUE);
    }

    /**
     * Returns the maximum element, or -Double.MAX_VALUE if empty.
     * @return maximum element, or -Double.MAX_VALUE if empty
     */
    public double max() {
        return reduce(CommonOps.naturalDoubleMaxReducer(), -Double.MAX_VALUE);
    }

    /**
     * Returns the maximum element, or -Double.MAX_VALUE if empty.
     * @param comparator the comparator
     * @return maximum element, or -Double.MAX_VALUE if empty
     */
    public double max(DoubleComparator comparator) {
        return reduce(CommonOps.doubleMaxReducer(comparator), -Double.MAX_VALUE);
    }

    /**
     * Returns the sum of elements.
     * @return the sum of elements
     */
    public double sum() {
        return reduce(CommonOps.doubleAdder(), 0.0);
    }

    /**
     * Returns summary statistics.
     * @param comparator the comparator to use for
     * locating minimum and maximum elements
     * @return the summary
     */
    public ParallelDoubleArray.SummaryStatistics summary
        (DoubleComparator comparator) {
        PAS.FJDStats f = new PAS.FJDStats
            (this, origin, fence, null, comparator);
        ex.invoke(f);
        return f;
    }

    /**
     * Returns summary statistics, using natural comparator.
     * @return the summary
     */
    public ParallelDoubleArray.SummaryStatistics summary() {
        return summary(CommonOps.naturalDoubleComparator());
    }

    /**
     * Returns a new ParallelDoubleArray holding mappings.
     * @return a new ParallelDoubleArray holding mappings
     */
    public ParallelDoubleArray all() {
        return new ParallelDoubleArray(ex, allDoubles());
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on mapped elements of the array using the given op.
     * @param op the op
     * @return operation prefix
     */
    public abstract ParallelArrayWithDoubleMapping<T> withMapping(DoubleOp op);

    /**
     * Returns an operation prefix that causes a method to operate
     * on mapped elements of the array using the given op.
     * @param op the op
     * @return operation prefix
     */
    public abstract ParallelArrayWithLongMapping<T> withMapping(DoubleToLong op);

    /**
     * Returns an operation prefix that causes a method to operate
     * on mapped elements of the array using the given op.
     * @param op the op
     * @return operation prefix
     */
    public abstract <U> ParallelArrayWithMapping<T,U> withMapping
        (DoubleToObject<? extends U> op);

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public <V,W,X> ParallelArrayWithMapping<T,W> withMapping
        (DoubleAndObjectToObject<? super V, ? extends W> combiner,
         ParallelArrayWithMapping<X,V> other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public <V> ParallelArrayWithMapping<T,V> withMapping
        (DoubleAndDoubleToObject<? extends V> combiner,
         ParallelDoubleArrayWithDoubleMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public <V> ParallelArrayWithMapping<T,V> withMapping
        (DoubleAndLongToObject<? extends V> combiner,
         ParallelLongArrayWithLongMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public <V,W> ParallelArrayWithDoubleMapping<T> withMapping
        (DoubleAndObjectToDouble<? super V> combiner,
         ParallelArrayWithMapping<W,V> other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public ParallelArrayWithDoubleMapping<T> withMapping
        (BinaryDoubleOp combiner,
         ParallelDoubleArrayWithDoubleMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public ParallelArrayWithDoubleMapping<T> withMapping
        (DoubleAndLongToDouble combiner,
         ParallelLongArrayWithLongMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public <V,W> ParallelArrayWithLongMapping<T> withMapping
        (DoubleAndObjectToLong<? super V> combiner,
         ParallelArrayWithMapping<W,V> other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public ParallelArrayWithLongMapping<T> withMapping
        (DoubleAndDoubleToLong combiner,
         ParallelDoubleArrayWithDoubleMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on binary mappings of this array and the other array.
     * @param combiner the combiner
     * @param other the other array
     * @return operation prefix
     */
    public ParallelArrayWithLongMapping<T> withMapping
        (DoubleAndLongToLong combiner,
         ParallelLongArrayWithLongMapping other) {
        return withIndexedMapping
            (AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
    }

    /**
     * Returns an operation prefix that causes a method to operate
     * on mappings of this array using the given mapper that
     * accepts as arguments an element's current index and value
     * (as mapped by preceding mappings, if any), and produces a
     * new value.
     * @param mapper the mapper
     * @return operation prefix
     */
    public abstract <V> ParallelArrayWithMapping<T,V> withIndexedMapping
        (IntAndDoubleToObject<? extends V> mapper);

    /**
     * Returns an operation prefix that causes a method to operate
     * on mappings of this array using the given mapper that
     * accepts as arguments an element's current index and value
     * (as mapped by preceding mappings, if any), and produces a
     * new value.
     * @param mapper the mapper
     * @return operation prefix
     */
    public abstract ParallelArrayWithDoubleMapping<T> withIndexedMapping
        (IntAndDoubleToDouble mapper);

    /**
     * Returns an operation prefix that causes a method to operate
     * on mappings of this array using the given mapper that
     * accepts as arguments an element's current index and value
     * (as mapped by preceding mappings, if any), and produces a
     * new value.
     * @param mapper the mapper
     * @return operation prefix
     */
    public abstract ParallelArrayWithLongMapping<T> withIndexedMapping
        (IntAndDoubleToLong mapper);

    /**
     * Returns an Iterable view to sequentially step through mapped
     * elements also obeying bound and filter constraints, without
     * performing computations to evaluate them in parallel.
     * @return the Iterable view
     */
    public Iterable<Double> sequentially() {
        return new SequentiallyAsDouble();
    }
}
Revision:	1.7
Committed:	Thu Feb 26 06:53:33 2015 UTC (9 years, 2 months ago) by jsr166
Branch:	MAIN
CVS Tags:	HEAD
Changes since 1.6:	+0 -1 lines
Log Message:	delete unused imports
#	User	Rev	Content
1	dl	1.1	/*
2			* Written by Doug Lea with assistance from members of JCP JSR-166
3			* Expert Group and released to the public domain, as explained at
4	jsr166	1.2	* http://creativecommons.org/publicdomain/zero/1.0/
5	dl	1.1	*/
6
7			package extra166y;
8	jsr166	1.6
9	dl	1.1	import jsr166y.*;
10			import static extra166y.Ops.*;
11			import java.util.*;
12			import java.util.concurrent.atomic.*;
13
14			/**
15			* A prefix view of ParallelArray that causes operations to apply
16			* to mappings of elements, not to the elements themselves.
17			* Instances of this class may be constructed only via prefix
18			* methods of ParallelArray or its other prefix classes.
19			*/
20			public abstract class ParallelArrayWithDoubleMapping<T> extends AbstractParallelAnyArray.OPap<T> {
21			ParallelArrayWithDoubleMapping
22			(ForkJoinPool ex, int origin, int fence, T[] array) {
23			super(ex, origin, fence, array);
24			}
25
26			/**
27	jsr166	1.4	* Applies the given procedure.
28	dl	1.1	* @param procedure the procedure
29			*/
30			public void apply(DoubleProcedure procedure) {
31			ex.invoke(new PAS.FJDApply(this, origin, fence, null, procedure));
32			}
33
34			/**
35	jsr166	1.4	* Returns reduction of mapped elements.
36	dl	1.1	* @param reducer the reducer
37			* @param base the result for an empty array
38			* @return reduction
39			*/
40			public double reduce(DoubleReducer reducer, double base) {
41			PAS.FJDReduce f = new PAS.FJDReduce
42			(this, origin, fence, null, reducer, base);
43			ex.invoke(f);
44			return f.result;
45			}
46
47			/**
48	jsr166	1.4	* Returns the minimum element, or Double.MAX_VALUE if empty.
49	dl	1.1	* @return minimum element, or Double.MAX_VALUE if empty
50			*/
51			public double min() {
52			return reduce(CommonOps.naturalDoubleMinReducer(), Double.MAX_VALUE);
53			}
54
55			/**
56	jsr166	1.4	* Returns the minimum element, or Double.MAX_VALUE if empty.
57	dl	1.1	* @param comparator the comparator
58			* @return minimum element, or Double.MAX_VALUE if empty
59			*/
60			public double min(DoubleComparator comparator) {
61			return reduce(CommonOps.doubleMinReducer(comparator), Double.MAX_VALUE);
62			}
63
64			/**
65	jsr166	1.4	* Returns the maximum element, or -Double.MAX_VALUE if empty.
66	dl	1.1	* @return maximum element, or -Double.MAX_VALUE if empty
67			*/
68			public double max() {
69			return reduce(CommonOps.naturalDoubleMaxReducer(), -Double.MAX_VALUE);
70			}
71
72			/**
73	jsr166	1.4	* Returns the maximum element, or -Double.MAX_VALUE if empty.
74	dl	1.1	* @param comparator the comparator
75			* @return maximum element, or -Double.MAX_VALUE if empty
76			*/
77			public double max(DoubleComparator comparator) {
78			return reduce(CommonOps.doubleMaxReducer(comparator), -Double.MAX_VALUE);
79			}
80
81			/**
82	jsr166	1.4	* Returns the sum of elements.
83	dl	1.1	* @return the sum of elements
84			*/
85			public double sum() {
86			return reduce(CommonOps.doubleAdder(), 0.0);
87			}
88
89			/**
90	jsr166	1.4	* Returns summary statistics.
91	dl	1.1	* @param comparator the comparator to use for
92			* locating minimum and maximum elements
93	jsr166	1.4	* @return the summary
94	dl	1.1	*/
95			public ParallelDoubleArray.SummaryStatistics summary
96			(DoubleComparator comparator) {
97			PAS.FJDStats f = new PAS.FJDStats
98			(this, origin, fence, null, comparator);
99			ex.invoke(f);
100			return f;
101			}
102
103			/**
104	jsr166	1.4	* Returns summary statistics, using natural comparator.
105			* @return the summary
106	dl	1.1	*/
107			public ParallelDoubleArray.SummaryStatistics summary() {
108			return summary(CommonOps.naturalDoubleComparator());
109			}
110
111			/**
112	jsr166	1.4	* Returns a new ParallelDoubleArray holding mappings.
113	dl	1.1	* @return a new ParallelDoubleArray holding mappings
114			*/
115			public ParallelDoubleArray all() {
116			return new ParallelDoubleArray(ex, allDoubles());
117			}
118
119			/**
120			* Returns an operation prefix that causes a method to operate
121			* on mapped elements of the array using the given op.
122			* @param op the op
123			* @return operation prefix
124			*/
125			public abstract ParallelArrayWithDoubleMapping<T> withMapping(DoubleOp op);
126
127			/**
128			* Returns an operation prefix that causes a method to operate
129			* on mapped elements of the array using the given op.
130			* @param op the op
131			* @return operation prefix
132			*/
133			public abstract ParallelArrayWithLongMapping<T> withMapping(DoubleToLong op);
134
135			/**
136			* Returns an operation prefix that causes a method to operate
137			* on mapped elements of the array using the given op.
138			* @param op the op
139			* @return operation prefix
140			*/
141	jsr166	1.5	public abstract <U> ParallelArrayWithMapping<T,U> withMapping
142	dl	1.1	(DoubleToObject<? extends U> op);
143
144			/**
145			* Returns an operation prefix that causes a method to operate
146			* on binary mappings of this array and the other array.
147			* @param combiner the combiner
148			* @param other the other array
149			* @return operation prefix
150			*/
151			public <V,W,X> ParallelArrayWithMapping<T,W> withMapping
152			(DoubleAndObjectToObject<? super V, ? extends W> combiner,
153			ParallelArrayWithMapping<X,V> other) {
154			return withIndexedMapping
155			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
156			}
157
158			/**
159			* Returns an operation prefix that causes a method to operate
160			* on binary mappings of this array and the other array.
161			* @param combiner the combiner
162			* @param other the other array
163			* @return operation prefix
164			*/
165			public <V> ParallelArrayWithMapping<T,V> withMapping
166			(DoubleAndDoubleToObject<? extends V> combiner,
167			ParallelDoubleArrayWithDoubleMapping other) {
168			return withIndexedMapping
169			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
170			}
171
172			/**
173			* Returns an operation prefix that causes a method to operate
174			* on binary mappings of this array and the other array.
175			* @param combiner the combiner
176			* @param other the other array
177			* @return operation prefix
178			*/
179			public <V> ParallelArrayWithMapping<T,V> withMapping
180			(DoubleAndLongToObject<? extends V> combiner,
181			ParallelLongArrayWithLongMapping other) {
182			return withIndexedMapping
183			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
184			}
185
186			/**
187			* Returns an operation prefix that causes a method to operate
188			* on binary mappings of this array and the other array.
189			* @param combiner the combiner
190			* @param other the other array
191			* @return operation prefix
192			*/
193			public <V,W> ParallelArrayWithDoubleMapping<T> withMapping
194			(DoubleAndObjectToDouble<? super V> combiner,
195			ParallelArrayWithMapping<W,V> other) {
196			return withIndexedMapping
197			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
198			}
199
200			/**
201			* Returns an operation prefix that causes a method to operate
202			* on binary mappings of this array and the other array.
203			* @param combiner the combiner
204			* @param other the other array
205			* @return operation prefix
206			*/
207			public ParallelArrayWithDoubleMapping<T> withMapping
208			(BinaryDoubleOp combiner,
209			ParallelDoubleArrayWithDoubleMapping other) {
210			return withIndexedMapping
211			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
212			}
213
214			/**
215			* Returns an operation prefix that causes a method to operate
216			* on binary mappings of this array and the other array.
217			* @param combiner the combiner
218			* @param other the other array
219			* @return operation prefix
220			*/
221			public ParallelArrayWithDoubleMapping<T> withMapping
222			(DoubleAndLongToDouble combiner,
223			ParallelLongArrayWithLongMapping other) {
224			return withIndexedMapping
225			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
226			}
227
228			/**
229			* Returns an operation prefix that causes a method to operate
230			* on binary mappings of this array and the other array.
231			* @param combiner the combiner
232			* @param other the other array
233			* @return operation prefix
234			*/
235			public <V,W> ParallelArrayWithLongMapping<T> withMapping
236			(DoubleAndObjectToLong<? super V> combiner,
237			ParallelArrayWithMapping<W,V> other) {
238			return withIndexedMapping
239			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
240			}
241
242			/**
243			* Returns an operation prefix that causes a method to operate
244			* on binary mappings of this array and the other array.
245			* @param combiner the combiner
246			* @param other the other array
247			* @return operation prefix
248			*/
249			public ParallelArrayWithLongMapping<T> withMapping
250			(DoubleAndDoubleToLong combiner,
251			ParallelDoubleArrayWithDoubleMapping other) {
252			return withIndexedMapping
253			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
254			}
255
256			/**
257			* Returns an operation prefix that causes a method to operate
258			* on binary mappings of this array and the other array.
259			* @param combiner the combiner
260			* @param other the other array
261			* @return operation prefix
262			*/
263			public ParallelArrayWithLongMapping<T> withMapping
264			(DoubleAndLongToLong combiner,
265			ParallelLongArrayWithLongMapping other) {
266			return withIndexedMapping
267			(AbstractParallelAnyArray.indexedMapper(combiner, other, origin));
268			}
269
270			/**
271			* Returns an operation prefix that causes a method to operate
272			* on mappings of this array using the given mapper that
273			* accepts as arguments an element's current index and value
274			* (as mapped by preceding mappings, if any), and produces a
275			* new value.
276			* @param mapper the mapper
277			* @return operation prefix
278			*/
279			public abstract <V> ParallelArrayWithMapping<T,V> withIndexedMapping
280			(IntAndDoubleToObject<? extends V> mapper);
281
282			/**
283			* Returns an operation prefix that causes a method to operate
284			* on mappings of this array using the given mapper that
285			* accepts as arguments an element's current index and value
286			* (as mapped by preceding mappings, if any), and produces a
287			* new value.
288			* @param mapper the mapper
289			* @return operation prefix
290			*/
291			public abstract ParallelArrayWithDoubleMapping<T> withIndexedMapping
292			(IntAndDoubleToDouble mapper);
293
294			/**
295			* Returns an operation prefix that causes a method to operate
296			* on mappings of this array using the given mapper that
297			* accepts as arguments an element's current index and value
298			* (as mapped by preceding mappings, if any), and produces a
299			* new value.
300			* @param mapper the mapper
301			* @return operation prefix
302			*/
303			public abstract ParallelArrayWithLongMapping<T> withIndexedMapping
304			(IntAndDoubleToLong mapper);
305
306			/**
307			* Returns an Iterable view to sequentially step through mapped
308			* elements also obeying bound and filter constraints, without
309	jsr166	1.4	* performing computations to evaluate them in parallel.
310	dl	1.1	* @return the Iterable view
311			*/
312			public Iterable<Double> sequentially() {
313			return new SequentiallyAsDouble();
314			}
315			}