org.semanticweb.elk.util.concurrent.computation
Interface InputProcessorFactory<I,P extends InputProcessor<I>>

Type Parameters:

I - the type of the input processed by the input processors

P - the type of the input processors produced by this factory

public interface InputProcessorFactory<I,P extends InputProcessor<I>>

An factory for creation of input processor engines of a given type. This factory is intended to be used in ConcurrentComputation to process the input concurrently by independent workers. In this case, an engine will be created for every worker. This allows one to store some worker-local objects in engines as well as shared objects to obtain an optimal performance of the computation.

Author:

"Yevgeny Kazakov"

Method Summary

void	finish() a hook function to be called when all jobs are processed
P	getEngine()

Method Detail

getEngine

P getEngine()

Returns:

a new input processor of the given type

finish

void finish()

a hook function to be called when all jobs are processed