Package dev.getelements.elements.rt.util

Class LatchedExecutorServiceCompletionService

java.lang.Object

dev.getelements.elements.rt.util.LatchedExecutorServiceCompletionService

Direct Known Subclasses:

LatchedScheduledExecutorServiceCompletionService

public class LatchedExecutorServiceCompletionService
extends Object

Manages tasks queued to an instance of ExecutorService managing execution through a CompletionServiceLatch. Unlike the builtin JDK Executor Completion Service this allows for multiple returned Future<?> types and only tracks the number of tasks. This allows for the tracking of a specific subset of tasks kicked off by an ExecutorService which may be shared by multiple objects.

Constructor Summary

Constructors

Constructor	Description
LatchedExecutorServiceCompletionService(ExecutorService executorService)	Creates a new instance of LatchedExecutorServiceCompletionService with the executor service and the default CompletionServiceLatch.
LatchedExecutorServiceCompletionService(ExecutorService executorService, CompletionServiceLatch latch)	Creates a new instance of LatchedExecutorServiceCompletionService with the executor service and a custom CompletionServiceLatch.

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable runnable)
void	stop()	Invokes CompletionServiceLatch.stop() for the CompletionServiceLatch associated with this LatchedExecutorServiceCompletionService.
Future<?>	submit(Runnable runnable)
<T> Future<T>	submit(Runnable runnable, T t)
<T> Future<T>	submit(Callable<T> callable)

Methods inherited from class java.lang.Object

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

Constructor Details

LatchedExecutorServiceCompletionService

public LatchedExecutorServiceCompletionService(ExecutorService executorService)

Creates a new instance of LatchedExecutorServiceCompletionService with the executor service and the default CompletionServiceLatch.

Parameters:

executorService - the ExecutorService to use

LatchedExecutorServiceCompletionService

public LatchedExecutorServiceCompletionService(ExecutorService executorService,
 CompletionServiceLatch latch)

Creates a new instance of LatchedExecutorServiceCompletionService with the executor service and a custom CompletionServiceLatch.

Parameters:

executorService - the ExecutorService to use

Method Details

submit

public <T> Future<T> submit(Callable<T> callable)

submit

public <T> Future<T> submit(Runnable runnable,
 T t)

submit

public Future<?> submit(Runnable runnable)

execute

public void execute(Runnable runnable)

stop

public void stop()

Invokes CompletionServiceLatch.stop() for the CompletionServiceLatch associated with this LatchedExecutorServiceCompletionService.