groovyx.gpars.util
Class PAUtils

java.lang.Object
  groovyx.gpars.util.PAUtils

public abstract class PAUtils
extends java.lang.Object

Handy methods build PA from different types

Author:

Vaclav Pech Date: 24th Oct 2010

Constructor Summary

PAUtils()

Method Summary

static <T> groovy.lang.Closure<T>	buildClosureForMaps(groovy.lang.Closure<T> cl) If the passed-in closure expects two arguments, it is considered to be a map-iterative code and is then wrapped with a single-argument closure, which unwraps the key:value pairs for the original closure.
static <T> groovy.lang.Closure<T>	buildClosureForMapsWithIndex(groovy.lang.Closure<T> cl) If the passed-in closure expects three arguments, it is considered to be a map-iterative_with_index code and is then wrapped with a two-argument closure, which unwraps the key:value pairs for the original closure.
static <K,V> java.util.Map<K,V>	buildResultMap(java.util.Collection<java.util.Map.Entry<K,V>> result) Builds a resulting map out of an map entry collection
static java.lang.String[]	createArray(java.lang.CharSequence value)
static <K,V> java.util.Map.Entry<K,V>[]	createArray(java.util.Map<K,V> map)
static <T> java.util.Collection<T>	createCollection(java.lang.Iterable<T> object)
static <T> java.util.Collection<T>	createCollection(java.util.Iterator<T> iterator)
static java.util.Comparator<java.lang.Object>	createComparator(groovy.lang.Closure<java.lang.Object> handler) Builds a comparator depending on the number of arguments accepted by the supplied closure.
static <K,T> groovy.lang.Closure<java.lang.Object>	createGroupByClosure(groovy.lang.Closure<K> cl, java.util.concurrent.ConcurrentMap<K,java.util.List<T>> map) Creates a closure that will insert elements in the appropriate group
static <T> void	evaluateArguments(Pool pool, java.lang.Object[] args, int current, java.util.List<java.lang.Object> soFarArgs, DataflowVariable<java.lang.Object> result, groovy.lang.Closure<T> original, boolean pooledThreadFlag) Performs a single step in the evaluation of parameters passed into an asynchronous function

Methods inherited from class java.lang.Object

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

Constructor Detail

PAUtils

public PAUtils()

Method Detail

createCollection

public static <T> java.util.Collection<T> createCollection(java.lang.Iterable<T> object)

createCollection

public static <T> java.util.Collection<T> createCollection(java.util.Iterator<T> iterator)

createArray

public static java.lang.String[] createArray(java.lang.CharSequence value)

createArray

public static <K,V> java.util.Map.Entry<K,V>[] createArray(java.util.Map<K,V> map)

buildClosureForMaps

public static <T> groovy.lang.Closure<T> buildClosureForMaps(groovy.lang.Closure<T> cl)

If the passed-in closure expects two arguments, it is considered to be a map-iterative code and is then wrapped with a single-argument closure, which unwraps the key:value pairs for the original closure. If the supplied closure doesn't expect two arguments, it is returned unchanged.

Parameters:

cl - The closure to use for parallel methods

Returns:

The original or an unwrapping closure

buildClosureForMapsWithIndex

public static <T> groovy.lang.Closure<T> buildClosureForMapsWithIndex(groovy.lang.Closure<T> cl)

If the passed-in closure expects three arguments, it is considered to be a map-iterative_with_index code and is then wrapped with a two-argument closure, which unwraps the key:value pairs for the original closure. If the supplied closure doesn't expect three arguments, it is returned unchanged.

Parameters:

cl - The closure to use for parallel methods

Returns:

The original or an unwrapping closure

buildResultMap

public static <K,V> java.util.Map<K,V> buildResultMap(java.util.Collection<java.util.Map.Entry<K,V>> result)

Builds a resulting map out of an map entry collection

Parameters:

result - The collection containing map entries

Returns:

A corresponding map instance

createComparator

public static java.util.Comparator<java.lang.Object> createComparator(groovy.lang.Closure<java.lang.Object> handler)

Builds a comparator depending on the number of arguments accepted by the supplied closure.

Parameters:

handler - The one or two argument closure to build a comparator on

Returns:

A new Comparator to use

createGroupByClosure

public static <K,T> groovy.lang.Closure<java.lang.Object> createGroupByClosure(groovy.lang.Closure<K> cl,
                                                                               java.util.concurrent.ConcurrentMap<K,java.util.List<T>> map)

Creates a closure that will insert elements in the appropriate group

Parameters:

cl - The distinction closure

map - The map of groups to contribute to

Returns:

null

evaluateArguments

public static <T> void evaluateArguments(Pool pool,
                                         java.lang.Object[] args,
                                         int current,
                                         java.util.List<java.lang.Object> soFarArgs,
                                         DataflowVariable<java.lang.Object> result,
                                         groovy.lang.Closure<T> original,
                                         boolean pooledThreadFlag)

Performs a single step in the evaluation of parameters passed into an asynchronous function

Parameters:

pool - The thread pool to use

args - The list of original arguments

current - The index of the current argument to evaluate

soFarArgs - A list of arguments evaluated so far

result - The DFV expecting the function result to be bound to once calculated

original - The original non-asynchronous function to invoke once all arguments are available

pooledThreadFlag - Indicates, whether we now run in a pooled thread so we don't have to schedule the original function invocation, once all arguments have been bound