com.davidsoergel.conja

Class Parallel

java.lang.Object

com.davidsoergel.conja.Parallel

public class Parallel
extends Object

Version:

$Id$

Author:

David Soergel

Constructor Summary

Constructors

Constructor and Description
Parallel()

Method Summary

Methods

Modifier and Type	Method and Description
static void	emergencyAbort()
static <T> void	forEach(int repetitions, Function<Integer,Void> function)
static <T> void	forEach(Iterable<T> tasks, Function<T,Void> function)
static <T> void	forEach(Iterator<T> tasks, Function<T,Void> function)
static <T> void	forEach(ThreadSafeNextOnlyIterator<T> tasks, Function<T,Void> function)
static <T> void	forEachThread(Function<Integer,Void> function)
static <T,V> Map<T,V>	map(Iterable<T> tasks, Function<T,V> function)
static <T,V> Map<T,V>	map(Iterator<T> tasks, Function<T,V> function)
static <T,V> Map<T,V>	map(ThreadSafeNextOnlyIterator<T> tasks, Function<T,V> function)
static <T,V> ThreadSafeNextOnlyIterator<V>	mapStream(ThreadSafeNextOnlyIterator<T> tasks, Function<T,V> function)
static ThreadPoolPerformanceStats	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

Parallel

public Parallel()

Method Detail

forEach

public static <T> void forEach(ThreadSafeNextOnlyIterator<T> tasks,
               Function<T,Void> function)

forEach

public static <T> void forEach(Iterator<T> tasks,
               Function<T,Void> function)

forEach

public static <T> void forEach(int repetitions,
               Function<Integer,Void> function)

forEachThread

public static <T> void forEachThread(Function<Integer,Void> function)

emergencyAbort

public static void emergencyAbort()

forEach

public static <T> void forEach(Iterable<T> tasks,
               Function<T,Void> function)

map

public static <T,V> Map<T,V> map(ThreadSafeNextOnlyIterator<T> tasks,
                 Function<T,V> function)

mapStream

public static <T,V> ThreadSafeNextOnlyIterator<V> mapStream(ThreadSafeNextOnlyIterator<T> tasks,
                                            Function<T,V> function)

map

public static <T,V> Map<T,V> map(Iterator<T> tasks,
                 Function<T,V> function)

map

public static <T,V> Map<T,V> map(Iterable<T> tasks,
                 Function<T,V> function)

shutdown

public static ThreadPoolPerformanceStats shutdown()