Package org.semanticweb.elk.util.concurrent.computation

Interface Summary

Interface	Description
InputProcessor<J>	An abstract interface for submitting and processing jobs of a certain type.
InputProcessorFactory<I,P extends InputProcessor<I>>	An factory for creation of input processor engines of a given type.
InputProcessorListenerNotifyFinishedJob<J>	A listener to be used with InputProcessor that can be used to perform actions when a job is processed.
Interrupter	An abstract interface for interrupting computations.

Class Summary

Class	Description
BaseInputProcessor<J>	FIXME delete it, the queue is not supposed to be local to the worker Implements basic job queueing and lets subclasses focus on processing single jobs
ComputationExecutor	A custom ExecutorService for starting a several copies of runnable tasks, and waiting for it computation; it allows to interrupt all running tasks without shutting down the ExecutorService.
ComputationThreadGroup	Thread groups used by this executor
ConcurrentComputation<I,F extends InputProcessorFactory<I,?>>	An class for concurrent processing of a number of tasks.
DelegatingInputProcessor<J>
SimpleInterrupter	A simple interrupter, which uses a flag about the interrupt status

Exception Summary

Exception	Description
ComputationRuntimeException