nl.weeaboo.vn.buildtools.optimizer

Interface IParallelExecutor

public interface IParallelExecutor

Represents a thread pool capable of running tasks on multiple processor cores.

Method Summary

Modifier and Type	Method and Description
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAndWait(java.util.Collection<java.util.concurrent.Callable<T>> tasks) Runs the given tasks in parallel.
default <T> java.util.List<java.util.concurrent.Future<java.lang.Void>>	invokeAndWait(java.lang.Iterable<T> inputs, java.util.function.Consumer<T> inputProcessingTask) Convenience method for applying a fixed function on a sequence of input values.

Method Detail

invokeAndWait

<T> java.util.List<java.util.concurrent.Future<T>> invokeAndWait(java.util.Collection<java.util.concurrent.Callable<T>> tasks)
                                                          throws java.lang.InterruptedException

Runs the given tasks in parallel. Blocks until all tasks have finished.

Returns:

A Future per submitted task that can be used to query the task's result.

Throws:

java.lang.InterruptedException - If the current thread is interrupted while still waiting for one or more tasks to finish.

invokeAndWait

default <T> java.util.List<java.util.concurrent.Future<java.lang.Void>> invokeAndWait(java.lang.Iterable<T> inputs,
                                                                                      java.util.function.Consumer<T> inputProcessingTask)
                                                                               throws java.lang.InterruptedException

Convenience method for applying a fixed function on a sequence of input values.

Throws:

java.lang.InterruptedException - If the current thread is interrupted while still waiting for one or more tasks to finish.