Class Dispatcher<T>

java.lang.Object

com.pivovarit.collectors.Dispatcher<T>

final class Dispatcher<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	Dispatcher.InterruptibleCompletableFuture<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final CompletableFuture<Void>	completionSignaller
private final Executor	executor
private final Semaphore	limiter
private static final Runnable	POISON_PILL
private boolean	shortCircuited
private final AtomicBoolean	started
private final BlockingQueue<Runnable>	workingQueue

Constructor Summary

Constructors

Modifier	Constructor	Description
private	Dispatcher()
private	Dispatcher(int permits)
private	Dispatcher(Executor executor, int permits)

Method Summary

Modifier and Type	Method	Description
private FutureTask<Void>	completionTask(Supplier<T> supplier, Dispatcher.InterruptibleCompletableFuture<T> future)
private static ExecutorService	defaultExecutorService()
(package private) CompletableFuture<T>	enqueue(Supplier<T> supplier)
(package private) static <T> Dispatcher<T>	from(Executor executor, int permits)
private void	handle(Throwable e)
(package private) boolean	isRunning()
private static void	requireValidExecutor(Executor executor)
private static void	retry(Runnable runnable)
private static Function<Throwable, Void>	shortcircuit(Dispatcher.InterruptibleCompletableFuture<?> future)
(package private) void	start()
(package private) void	stop()
(package private) static <T> Dispatcher<T>	virtual()
(package private) static <T> Dispatcher<T>	virtual(int permits)

Methods inherited from class Object

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

Field Details

POISON_PILL

private static final Runnable POISON_PILL

completionSignaller

private final CompletableFuture<Void> completionSignaller

workingQueue

private final BlockingQueue<Runnable> workingQueue

executor

private final Executor executor

limiter

private final Semaphore limiter

started

private final AtomicBoolean started

shortCircuited

private volatile boolean shortCircuited

Constructor Details

Dispatcher

private Dispatcher()

Dispatcher

private Dispatcher(Executor executor,
 int permits)

Dispatcher

private Dispatcher(int permits)

Method Details

from

static <T> Dispatcher<T> from(Executor executor,
 int permits)

virtual

static <T> Dispatcher<T> virtual()

virtual

static <T> Dispatcher<T> virtual(int permits)

start

void start()

stop

void stop()

isRunning

boolean isRunning()

enqueue

CompletableFuture<T> enqueue(Supplier<T> supplier)

completionTask

private FutureTask<Void> completionTask(Supplier<T> supplier,
 Dispatcher.InterruptibleCompletableFuture<T> future)

handle

private void handle(Throwable e)

shortcircuit

private static Function<Throwable, Void> shortcircuit(Dispatcher.InterruptibleCompletableFuture<?> future)

defaultExecutorService

private static ExecutorService defaultExecutorService()

requireValidExecutor

private static void requireValidExecutor(Executor executor)

retry

private static void retry(Runnable runnable)