Constructor Detail

• PAUtils()

Method Detail

• public static 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.

  Returns:

  The original or an unwrapping closure

  Parameters:

  cl - The closure to use for parallel methods

• public static 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.

  Returns:

  The original or an unwrapping closure

  Parameters:

  cl - The closure to use for parallel methods

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

  Builds a resulting map out of an map entry collection

  Returns:

  A corresponding map instance

  Parameters:

  result - The collection containing map entries

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

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

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

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

• 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.

  Returns:

  A new Comparator to use

  Parameters:

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

• public static 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

  Returns:

  null

  Parameters:

  cl - The distinction closure

  map - The map of groups to contribute to

• @java.lang.SuppressWarnings({"unchecked"}) public static 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