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

All Superinterfaces:

Interrupter

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

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

Methods

Modifier and Type	Method and Description
void	finish() a hook function to be called when all jobs are successfully processed
P	getEngine()

Methods inherited from interface org.semanticweb.elk.util.concurrent.computation.Interrupter

isInterrupted, setInterrupt

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 successfully processed