net.imglib2.algorithm.util

Class ParallelizeOverBlocks

java.lang.Object

net.imglib2.algorithm.util.ParallelizeOverBlocks

public class ParallelizeOverBlocks
extends Object

Author:

Philipp Hanslovsky Utility methods to parallelize image processing tasks in blocks

Constructor Summary

Constructors

Constructor and Description
ParallelizeOverBlocks()

Method Summary

Modifier and Type	Method and Description
static <T> Function<T,Void>	ofConsumer(Consumer<T> consumer) Utility method to turn a Consumer into a Function.
static <T> List<Future<List<T>>>	parallelize(Function<net.imglib2.Interval,T> func, net.imglib2.Interval interval, int[] blockSize, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.
static <T> List<Future<List<T>>>	parallelize(Function<net.imglib2.Interval,T> func, List<net.imglib2.Interval> blocks, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.
static <T> List<Future<List<T>>>	parallelize(Function<net.imglib2.Interval,T> func, long[] min, long[] max, int[] blockSize, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.
static <T> List<T>	parallelizeAndWait(Function<net.imglib2.Interval,T> func, net.imglib2.Interval interval, int[] blockSize, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.
static <T> List<T>	parallelizeAndWait(Function<net.imglib2.Interval,T> func, List<net.imglib2.Interval> blocks, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.
static <T> List<T>	parallelizeAndWait(Function<net.imglib2.Interval,T> func, long[] min, long[] max, int[] blockSize, ExecutorService es, int numTasks) Submit blocked tasks and wait for execution.

Methods inherited from class java.lang.Object

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

Constructor Detail

ParallelizeOverBlocks

public ParallelizeOverBlocks()

Method Detail

parallelizeAndWait

public static <T> List<T> parallelizeAndWait(Function<net.imglib2.Interval,T> func,
                                             net.imglib2.Interval interval,
                                             int[] blockSize,
                                             ExecutorService es,
                                             int numTasks)
                                      throws InterruptedException,
                                             ExecutionException

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

interval -

blockSize -

es -

numTasks -

Returns:

List of results of computation. Note that for computations that return void, this should be a list of Void.

Throws:

InterruptedException

ExecutionException

parallelize

public static <T> List<Future<List<T>>> parallelize(Function<net.imglib2.Interval,T> func,
                                                    net.imglib2.Interval interval,
                                                    int[] blockSize,
                                                    ExecutorService es,
                                                    int numTasks)

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

interval -

blockSize -

es -

numTasks -

Returns:

List of futures of the submitted tasks. Each future contains a list of results.

parallelizeAndWait

public static <T> List<T> parallelizeAndWait(Function<net.imglib2.Interval,T> func,
                                             long[] min,
                                             long[] max,
                                             int[] blockSize,
                                             ExecutorService es,
                                             int numTasks)
                                      throws InterruptedException,
                                             ExecutionException

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

min -

max -

blockSize -

es -

numTasks -

Returns:

List of results of computation. Note that for computations that return void, this should be a list of Void.

Throws:

InterruptedException

ExecutionException

parallelize

public static <T> List<Future<List<T>>> parallelize(Function<net.imglib2.Interval,T> func,
                                                    long[] min,
                                                    long[] max,
                                                    int[] blockSize,
                                                    ExecutorService es,
                                                    int numTasks)

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

min -

max -

blockSize -

es -

numTasks -

Returns:

List of futures of the submitted tasks. Each future contains a list of results.

parallelizeAndWait

public static <T> List<T> parallelizeAndWait(Function<net.imglib2.Interval,T> func,
                                             List<net.imglib2.Interval> blocks,
                                             ExecutorService es,
                                             int numTasks)
                                      throws InterruptedException,
                                             ExecutionException

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

blocks -

es -

numTasks -

Returns:

List of results of computation. Note that for computations that return void, this should be a list of Void.

Throws:

InterruptedException

ExecutionException

parallelize

public static <T> List<Future<List<T>>> parallelize(Function<net.imglib2.Interval,T> func,
                                                    List<net.imglib2.Interval> blocks,
                                                    ExecutorService es,
                                                    int numTasks)

Submit blocked tasks and wait for execution.

Parameters:

func - Function to be applied to each block as specified by first parameter Interval.

blocks -

es -

numTasks -

Returns:

List of futures of the submitted tasks. Each future contains a list of results.

ofConsumer

public static <T> Function<T,Void> ofConsumer(Consumer<T> consumer)

Utility method to turn a Consumer into a Function.

Parameters:

consumer -

Returns: