@@ -28,11 +28,11 @@ private ParallelCollectors() {
28
28
* .collect(parallel(i -> foo(i), toList()));
29
29
* }</pre>
30
30
*
31
- * @param mapper a transformation to be performed in parallel
32
- * @param collector the {@code Collector} describing the reduction
33
- * @param <T> the type of the collected elements
34
- * @param <R> the result returned by {@code mapper}
35
- * @param <RR> the reduction result {@code collector}
31
+ * @param mapper a transformation to be performed in parallel
32
+ * @param collector the {@code Collector} describing the reduction
33
+ * @param <T> the type of the collected elements
34
+ * @param <R> the result returned by {@code mapper}
35
+ * @param <RR> the reduction result {@code collector}
36
36
*
37
37
* @return a {@code Collector} which collects all processed elements into a user-provided mutable {@code Collection} in parallel
38
38
*
@@ -106,12 +106,12 @@ private ParallelCollectors() {
106
106
* .collect(parallel(i -> foo(i), toList(), executor));
107
107
* }</pre>
108
108
*
109
- * @param mapper a transformation to be performed in parallel
110
- * @param collector the {@code Collector} describing the reduction
111
- * @param executor the {@code Executor} to use for asynchronous execution
112
- * @param <T> the type of the collected elements
113
- * @param <R> the result returned by {@code mapper}
114
- * @param <RR> the reduction result {@code collector}
109
+ * @param mapper a transformation to be performed in parallel
110
+ * @param collector the {@code Collector} describing the reduction
111
+ * @param executor the {@code Executor} to use for asynchronous execution
112
+ * @param <T> the type of the collected elements
113
+ * @param <R> the result returned by {@code mapper}
114
+ * @param <RR> the reduction result {@code collector}
115
115
*
116
116
* @return a {@code Collector} which collects all processed elements into a user-provided mutable {@code Collection} in parallel
117
117
*
@@ -135,9 +135,9 @@ private ParallelCollectors() {
135
135
* .collect(parallel(i -> foo()));
136
136
* }</pre>
137
137
*
138
- * @param mapper a transformation to be performed in parallel
139
- * @param <T> the type of the collected elements
140
- * @param <R> the result returned by {@code mapper}
138
+ * @param mapper a transformation to be performed in parallel
139
+ * @param <T> the type of the collected elements
140
+ * @param <R> the result returned by {@code mapper}
141
141
*
142
142
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
143
143
*
@@ -162,6 +162,7 @@ private ParallelCollectors() {
162
162
* }</pre>
163
163
*
164
164
* @param mapper a transformation to be performed in parallel
165
+ * @param parallelism the max parallelism level
165
166
* @param <T> the type of the collected elements
166
167
* @param <R> the result returned by {@code mapper}
167
168
*
@@ -215,10 +216,10 @@ private ParallelCollectors() {
215
216
* .collect(parallel(i -> foo(), executor));
216
217
* }</pre>
217
218
*
218
- * @param mapper a transformation to be performed in parallel
219
- * @param executor the {@code Executor} to use for asynchronous execution
220
- * @param <T> the type of the collected elements
221
- * @param <R> the result returned by {@code mapper}
219
+ * @param mapper a transformation to be performed in parallel
220
+ * @param executor the {@code Executor} to use for asynchronous execution
221
+ * @param <T> the type of the collected elements
222
+ * @param <R> the result returned by {@code mapper}
222
223
*
223
224
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
224
225
*
@@ -242,9 +243,9 @@ private ParallelCollectors() {
242
243
* .forEach(System.out::println);
243
244
* }</pre>
244
245
*
245
- * @param mapper a transformation to be performed in parallel
246
- * @param <T> the type of the collected elements
247
- * @param <R> the result returned by {@code mapper}
246
+ * @param mapper a transformation to be performed in parallel
247
+ * @param <T> the type of the collected elements
248
+ * @param <R> the result returned by {@code mapper}
248
249
*
249
250
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
250
251
*
@@ -295,10 +296,10 @@ private ParallelCollectors() {
295
296
* .forEach(System.out::println);
296
297
* }</pre>
297
298
*
298
- * @param mapper a transformation to be performed in parallel
299
- * @param executor the {@code Executor} to use for asynchronous execution
300
- * @param <T> the type of the collected elements
301
- * @param <R> the result returned by {@code mapper}
299
+ * @param mapper a transformation to be performed in parallel
300
+ * @param executor the {@code Executor} to use for asynchronous execution
301
+ * @param <T> the type of the collected elements
302
+ * @param <R> the result returned by {@code mapper}
302
303
*
303
304
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
304
305
*
@@ -350,9 +351,9 @@ private ParallelCollectors() {
350
351
* .forEach(System.out::println);
351
352
* }</pre>
352
353
*
353
- * @param mapper a transformation to be performed in parallel
354
- * @param <T> the type of the collected elements
355
- * @param <R> the result returned by {@code mapper}
354
+ * @param mapper a transformation to be performed in parallel
355
+ * @param <T> the type of the collected elements
356
+ * @param <R> the result returned by {@code mapper}
356
357
*
357
358
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
358
359
*
@@ -403,10 +404,10 @@ private ParallelCollectors() {
403
404
* .forEach(System.out::println);
404
405
* }</pre>
405
406
*
406
- * @param mapper a transformation to be performed in parallel
407
- * @param executor the {@code Executor} to use for asynchronous execution
408
- * @param <T> the type of the collected elements
409
- * @param <R> the result returned by {@code mapper}
407
+ * @param mapper a transformation to be performed in parallel
408
+ * @param executor the {@code Executor} to use for asynchronous execution
409
+ * @param <T> the type of the collected elements
410
+ * @param <R> the result returned by {@code mapper}
410
411
*
411
412
* @return a {@code Collector} which collects all processed elements into a {@code Stream} in parallel
412
413
*
0 commit comments