com.davidsoergel.conja
Class Parallel

java.lang.Object
  com.davidsoergel.conja.Parallel

public class Parallel
extends java.lang.Object

Version:

$Id$

Author:

David Soergel

Constructor Summary

Parallel()

Method Summary

static void	emergencyAbort()
static <T> void	forEach(int repetitions, Function<java.lang.Integer,java.lang.Void> function)
static <T> void	forEach(java.lang.Iterable<T> tasks, Function<T,java.lang.Void> function)
static <T> void	forEach(java.util.Iterator<T> tasks, Function<T,java.lang.Void> function)
static <T> void	forEach(ThreadSafeNextOnlyIterator<T> tasks, Function<T,java.lang.Void> function)
static <T> void	forEachThread(Function<java.lang.Integer,java.lang.Void> function)
static <T,V> java.util.Map<T,V>	map(java.lang.Iterable<T> tasks, Function<T,V> function)
static <T,V> java.util.Map<T,V>	map(java.util.Iterator<T> tasks, Function<T,V> function)
static <T,V> java.util.Map<T,V>	map(ThreadSafeNextOnlyIterator<T> tasks, Function<T,V> function)
static void	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,java.lang.Void> function)

forEach

public static <T> void forEach(java.util.Iterator<T> tasks,
                               Function<T,java.lang.Void> function)

forEach

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

forEachThread

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

emergencyAbort

public static void emergencyAbort()

forEach

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

map

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

map

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

map

public static <T,V> java.util.Map<T,V> map(java.lang.Iterable<T> tasks,
                                           Function<T,V> function)

shutdown

public static void shutdown()