Parallel-Iterable

Transform or filter collections concurrently

Just use the ParallelIterable like you would use the FluentIterable in Guava. The transformation or filtering of each element will be done concurrently behind the scenes.

Code sample

package be.dabla.parallel.iterable;

import static com.google.common.collect.Lists.newArrayList;
import static java.math.BigInteger.ONE;
import static java.math.BigInteger.ZERO;

import java.math.BigInteger;
import java.util.List;

import com.google.common.base.Function;

public class Sample {
    
    public List<BigInteger> incrementAllByOne() {
        return ParallelIterable.from(newArrayList(ZERO, ONE))
                        	   .transform(addOne())
                        	   .toList();
    }
    
    private Function<BigInteger, BigInteger> addOne() {
        return new Function<BigInteger, BigInteger>() {
            public BigInteger apply(BigInteger input) {
                return input.add(ONE);
            }
        };
    }
}

How to use in your project

Example for Maven:

<dependency>
    <groupId>be.dabla</groupId>
    <artifactId>parallel-iterable</artifactId>
    <version>1.4</version>
</dependency>

Maven artifact can be found at https://oss.sonatype.org/content/repositories/public/be/dabla/parallel-iterable