org.semanticweb.elk.reasoner

Class ReasonerComputation<I,F extends InputProcessorFactory<I,?>>

java.lang.Object

org.semanticweb.elk.util.concurrent.computation.SimpleInterrupter

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

All Implemented Interfaces:

Interrupter

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

Fields

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	process() Process the given input concurrently using the provided input processor.

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

finish, getInputProcessorFactory, setInterrupt, start, submit, waitWorkers

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

isInterrupted

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.