org.trancecode.concurrent

Class ParallelIterables

java.lang.Object

org.trancecode.concurrent.ParallelIterables

public final class ParallelIterables
extends Object

Parallel equivalent of Iterables.

Author:

Herve Quiroz

Method Summary

Methods

Modifier and Type	Method and Description
static <T> Iterable<T>	filter(Iterable<T> unfiltered, com.google.common.base.Predicate<? super T> predicate, ExecutorService executor)
static <T> Iterable<T>	get(Iterable<Future<T>> futures)
static <F,T> Iterable<T>	transform(Iterable<F> fromIterable, com.google.common.base.Function<? super F,? extends T> function, ExecutorService executor)

Methods inherited from class java.lang.Object

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

Method Detail

transform

public static <F,T> Iterable<T> transform(Iterable<F> fromIterable,
                          com.google.common.base.Function<? super F,? extends T> function,
                          ExecutorService executor)

See Also:

Iterables.transform(Iterable, Function)

filter

public static <T> Iterable<T> filter(Iterable<T> unfiltered,
                     com.google.common.base.Predicate<? super T> predicate,
                     ExecutorService executor)

See Also:

Iterables.filter(Iterable, Predicate)

get

public static <T> Iterable<T> get(Iterable<Future<T>> futures)