com.groupon.lex.metrics.history.xdr.support

Class FJPTaskExecutor<T>

java.lang.Object

com.groupon.lex.metrics.history.xdr.support.FJPTaskExecutor<T>

public class FJPTaskExecutor<T>
extends Object

A task executor that runs tasks on a ForkJoinPool. The executor ensures not too many tasks are scheduled at once, so it won't starve other jobs running on the same pool.

Author:

ariane

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	FJPTaskExecutor.JobFunction<T>

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CONCURRENCY

Constructor Summary

Constructors

Constructor and Description
FJPTaskExecutor(Collection<T> datums, FJPTaskExecutor.JobFunction<T> jobFn)
FJPTaskExecutor(Collection<T> datums, FJPTaskExecutor.JobFunction<T> jobFn, int concurrency)

Method Summary

Modifier and Type	Method and Description
void	join()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CONCURRENCY

public static final int DEFAULT_CONCURRENCY

Constructor Detail

FJPTaskExecutor

public FJPTaskExecutor(@NonNull
                       Collection<T> datums,
                       @NonNull
                       FJPTaskExecutor.JobFunction<T> jobFn,
                       int concurrency)

FJPTaskExecutor

public FJPTaskExecutor(@NonNull
                       Collection<T> datums,
                       @NonNull
                       FJPTaskExecutor.JobFunction<T> jobFn)

Method Detail

join

public void join()