org.semanticweb.elk.reasoner
Class ReasonerComputation<I,F extends InputProcessorFactory<I,?>>

java.lang.Object
  org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation<I,F>
      org.semanticweb.elk.reasoner.ReasonerComputation<I,F>

Type Parameters:

I - the input that can be processed by the computation

F - the type of the factory for the input processors

Direct Known Subclasses:

ClassExpressionNoInputSaturation, ClassExpressionSaturation, ClassTaxonomyComputation, ConsistencyChecking, IncrementalChangesInitialization, InstanceTaxonomyComputation, PropertyHierarchyCompositionComputation, ReflexivePropertyComputation, TaxonomyCleaning

public class ReasonerComputation<I,F extends InputProcessorFactory<I,?>>
extends ConcurrentComputation<I,F>

A ConcurrentComputation used for executing of reasoner stages

Author:

"Yevgeny Kazakov"

Field Summary

protected ProgressMonitor	progressMonitor the progress monitor used to report the progress of this computation
protected Iterator<? extends I>	todo the inputs to be processed

Fields inherited from class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

buffer, executor, finishRequested, inputProcessorFactory, interrupted, maxWorkers, worker

Constructor Summary

ReasonerComputation(Collection<? extends I> inputs, F inputProcessorFactory, ComputationExecutor executor, int maxWorkers, ProgressMonitor progressMonitor)

Method Summary

void	process() Process the given input concurrently using the provided input processor.

Methods inherited from class org.semanticweb.elk.util.concurrent.computation.ConcurrentComputation

finish, interrupt, start, submit

Methods inherited from class java.lang.Object

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

Field Detail

progressMonitor

protected final ProgressMonitor progressMonitor

the progress monitor used to report the progress of this computation

todo

protected final Iterator<? extends I> todo

the inputs to be processed

Constructor Detail

ReasonerComputation

public ReasonerComputation(Collection<? extends I> inputs,
                           F inputProcessorFactory,
                           ComputationExecutor executor,
                           int maxWorkers,
                           ProgressMonitor progressMonitor)

Method Detail

process

public void process()

Process the given input concurrently using the provided input processor. If the process has been interrupted, this method can be called again to continue the computation.