com.github.nill14.utils.java8.stream

Class ExecutorUtils

java.lang.Object

com.github.nill14.utils.java8.stream.ExecutorUtils

public class ExecutorUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static <E,R> ImmutableList<R>	parallelExecution(ExecutorService executor, Collection<E> elements, Function<E,R> mappingFunction) Similar to parallel stream but executes in ExecutorService not ForkJoinPool.commonPool().

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

parallelExecution

public static <E,R> ImmutableList<R> parallelExecution(ExecutorService executor,
                                                       Collection<E> elements,
                                                       Function<E,R> mappingFunction)
                                                throws InterruptedException,
                                                       ExecutionException

Similar to parallel stream but executes in ExecutorService not ForkJoinPool.commonPool(). Another difference is that execution is always forked regardless of the job size.

Parameters:

executor -

elements -

mappingFunction -

Returns:

List of results from the mappingFunction

Throws:

InterruptedException

ExecutionException - when mappingFunction throws exception