com.saxonica.ee.trans

Class CountingCompletionService<V>

java.lang.Object

java.util.concurrent.ExecutorCompletionService<V>

com.saxonica.ee.trans.CountingCompletionService<V>

All Implemented Interfaces:

CompletionService<V>

public class CountingCompletionService<V>
extends ExecutorCompletionService<V>

Extension of ExecutorCompletionService to count the number of tasks submitted and take that many completed tasks before calling it a day.

This is necessary because the base class, ExecutorCompletionService, does not provide any way of knowing how many results you need to read off before you know that you have read them all.

Constructor Summary

Constructors

Constructor and Description
CountingCompletionService(Executor executor)
CountingCompletionService(Executor executor, BlockingQueue<Future<V>> queue)

Method Summary

Methods

Modifier and Type	Method and Description
long	getNumberOfCompletedTasks()
long	getNumberOfSubmittedTasks()
boolean	hasUncompletedTasks()
Future<V>	poll()
Future<V>	poll(long timeout, TimeUnit unit)
Future<V>	submit(Callable<V> task)
Future<V>	submit(Runnable task, V result)
Future<V>	take()

Methods inherited from class java.lang.Object

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

Constructor Detail

CountingCompletionService

public CountingCompletionService(Executor executor)

CountingCompletionService

public CountingCompletionService(Executor executor,
                         BlockingQueue<Future<V>> queue)

Method Detail

submit

public Future<V> submit(Callable<V> task)

Specified by:

submit in interface CompletionService<V>

Overrides:

submit in class ExecutorCompletionService<V>

submit

public Future<V> submit(Runnable task,
               V result)

Specified by:

submit in interface CompletionService<V>

Overrides:

submit in class ExecutorCompletionService<V>

take

public Future<V> take()
               throws InterruptedException

Specified by:

take in interface CompletionService<V>

Overrides:

take in class ExecutorCompletionService<V>

Throws:

InterruptedException

poll

public Future<V> poll()

Specified by:

poll in interface CompletionService<V>

Overrides:

poll in class ExecutorCompletionService<V>

poll

public Future<V> poll(long timeout,
             TimeUnit unit)
               throws InterruptedException

Specified by:

poll in interface CompletionService<V>

Overrides:

poll in class ExecutorCompletionService<V>

Throws:

InterruptedException

getNumberOfCompletedTasks

public long getNumberOfCompletedTasks()

getNumberOfSubmittedTasks

public long getNumberOfSubmittedTasks()

hasUncompletedTasks

public boolean hasUncompletedTasks()