Package com.saxonica.ee.parallel

Class CountingCompletionService<V>

java.lang.Object

java.util.concurrent.ExecutorCompletionService<V>

com.saxonica.ee.parallel.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	Description
CountingCompletionService(Executor executor)
CountingCompletionService(Executor executor, BlockingQueue<Future<V>> queue)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

CountingCompletionService

public CountingCompletionService(Executor executor)

CountingCompletionService

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

Method Details

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()