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

Interface Summary

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 and monitoring if computations have been interrupted.

Class Summary

BaseInputProcessor<J>	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 just stores the flag about the interrupt status and interrupts the thread that is assigned to this interrupter

Exception Summary

ComputationRuntimeException