Package io.karma.kommons.util

Class BatchProcessor

java.lang.Object

io.karma.kommons.util.BatchProcessor

@API(status=STABLE)
public final class BatchProcessor
extends Object

A simple, allocation-friendly alternative to parallel streams, which can process a collection of elements, scaling (mostly) symmetrically accross all available (or specified) threads.

Since:

04/08/2022

Method Summary

Modifier and Type	Method	Description
static <T, R, C extends Collection<R>, U> C	flatProcess(Collection<T> elements, BiFunction<T,U,? extends Collection<? extends R>> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	flatProcess(Collection<T> elements, Function<T,? extends Collection<? extends R>> function, Supplier<C> factory)
static <T, R, C extends Collection<R>, U> C	flatProcess(ExecutorService executor, Collection<T> elements, int numBatches, BiFunction<T,U,? extends Collection<? extends R>> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	flatProcess(ExecutorService executor, Collection<T> elements, int numBatches, Function<T,? extends Collection<? extends R>> function, Supplier<C> factory)
static <T, R, C extends Collection<R>, U> C	flatProcess(ExecutorService executor, Collection<T> elements, BiFunction<T,U,? extends Collection<? extends R>> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	flatProcess(ExecutorService executor, Collection<T> elements, Function<T,? extends Collection<? extends R>> function, Supplier<C> factory)
static <T, R, C extends Collection<R>, U> C	process(Collection<T> elements, BiFunction<T,U,R> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	process(Collection<T> elements, Function<T,R> function, Supplier<C> factory)
static <T, R, C extends Collection<R>, U> C	process(ExecutorService executor, Collection<T> elements, int numBatches, BiFunction<T,U,R> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	process(ExecutorService executor, Collection<T> elements, int numBatches, Function<T,R> function, Supplier<C> factory)
static <T, R, C extends Collection<R>, U> C	process(ExecutorService executor, Collection<T> elements, BiFunction<T,U,R> function, Supplier<C> factory, U userData)
static <T, R, C extends Collection<R>> C	process(ExecutorService executor, Collection<T> elements, Function<T,R> function, Supplier<C> factory)

Methods inherited from class java.lang.Object

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

Method Details

process

public static <T,
R,
C extends Collection<R>> C process(ExecutorService executor,
 Collection<T> elements,
 int numBatches,
 Function<T,R> function,
 Supplier<C> factory)

process

public static <T,
R,
C extends Collection<R>> C process(ExecutorService executor,
 Collection<T> elements,
 Function<T,R> function,
 Supplier<C> factory)

process

public static <T,
R,
C extends Collection<R>> C process(Collection<T> elements,
 Function<T,R> function,
 Supplier<C> factory)

flatProcess

public static <T,
R,
C extends Collection<R>> C flatProcess(ExecutorService executor,
 Collection<T> elements,
 int numBatches,
 Function<T,? extends Collection<? extends R>> function,
 Supplier<C> factory)

flatProcess

public static <T,
R,
C extends Collection<R>> C flatProcess(ExecutorService executor,
 Collection<T> elements,
 Function<T,? extends Collection<? extends R>> function,
 Supplier<C> factory)

flatProcess

public static <T,
R,
C extends Collection<R>> C flatProcess(Collection<T> elements,
 Function<T,? extends Collection<? extends R>> function,
 Supplier<C> factory)

process

public static <T,
R,
C extends Collection<R>,
U> C process(ExecutorService executor,
 Collection<T> elements,
 int numBatches,
 BiFunction<T,U,R> function,
 Supplier<C> factory,
 @Nullable
 U userData)

process

public static <T,
R,
C extends Collection<R>,
U> C process(ExecutorService executor,
 Collection<T> elements,
 BiFunction<T,U,R> function,
 Supplier<C> factory,
 @Nullable
 U userData)

process

public static <T,
R,
C extends Collection<R>,
U> C process(Collection<T> elements,
 BiFunction<T,U,R> function,
 Supplier<C> factory,
 @Nullable
 U userData)

flatProcess

public static <T,
R,
C extends Collection<R>,
U> C flatProcess(ExecutorService executor,
 Collection<T> elements,
 int numBatches,
 BiFunction<T,U,? extends Collection<? extends R>> function,
 Supplier<C> factory,
 @Nullable
 U userData)

flatProcess

public static <T,
R,
C extends Collection<R>,
U> C flatProcess(ExecutorService executor,
 Collection<T> elements,
 BiFunction<T,U,? extends Collection<? extends R>> function,
 Supplier<C> factory,
 @Nullable
 U userData)

flatProcess

public static <T,
R,
C extends Collection<R>,
U> C flatProcess(Collection<T> elements,
 BiFunction<T,U,? extends Collection<? extends R>> function,
 Supplier<C> factory,
 @Nullable
 U userData)