Package com.semedy.reasoner.reasoning.processes

Class ProcessExecutor

java.lang.Object

com.semedy.reasoner.reasoning.processes.ProcessExecutor

public class ProcessExecutor
extends Object

Stores and executes all processes necessary to answer to a query.

Author:

juergen

Constructor Summary

Constructors

Constructor	Description
ProcessExecutor()
ProcessExecutor(int maxstratum, int queryId)
ProcessExecutor(InterruptFlag interruptFlag, int maxstratum, int queryId)

Method Summary

Modifier and Type	Method	Description
void	addActiveStore(UnbufferedStore s)
void	addDataSource(Process task)
void	addProcess(Process task)
void	dispose()
void	evaluate()
void	evaluate(InterruptFlag interruptFlag, SimpleSemaphore semaphoreForSensors, CoreReadLock edbReadlock, Set<String> predicates)
void	evaluateConnectors()
void	evaluationFinished()
boolean	influenceOn(Process p)
void	push4Execution(long uid, ExecuteConnectorBuiltin executor)
void	queueForEvaluation(Process task)
void	queueForEvaluationInStratum(ProcessImp task, int stratum)
void	queueForEvaluationUnrestricted(Process task)
void	removeActiveStore(UnbufferedStore s)
void	removeOperator(Process task)
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessExecutor

public ProcessExecutor()

ProcessExecutor

public ProcessExecutor(int maxstratum,
 int queryId)

ProcessExecutor

public ProcessExecutor(InterruptFlag interruptFlag,
 int maxstratum,
 int queryId)

Method Details

addActiveStore

public void addActiveStore(UnbufferedStore s)

removeActiveStore

public void removeActiveStore(UnbufferedStore s)

reset

public void reset()
           throws SemReasonerException

Throws:

SemReasonerException

evaluationFinished

public void evaluationFinished()
                        throws SemReasonerException,
InterruptedException

Throws:

SemReasonerException

InterruptedException

dispose

public void dispose()

queueForEvaluationInStratum

public void queueForEvaluationInStratum(ProcessImp task,
 int stratum)

addProcess

public void addProcess(Process task)

push4Execution

public void push4Execution(long uid,
 ExecuteConnectorBuiltin executor)

queueForEvaluationUnrestricted

public void queueForEvaluationUnrestricted(Process task)

removeOperator

public void removeOperator(Process task)

addDataSource

public void addDataSource(Process task)

queueForEvaluation

public void queueForEvaluation(Process task)

influenceOn

public boolean influenceOn(Process p)

evaluate

public void evaluate(InterruptFlag interruptFlag,
 SimpleSemaphore semaphoreForSensors,
 CoreReadLock edbReadlock,
 Set<String> predicates)
              throws InterruptedException,
SemReasonerException,
IOException

Throws:

InterruptedException

SemReasonerException

IOException

evaluate

public void evaluate()
              throws InterruptedException,
SemReasonerException,
IOException

Throws:

InterruptedException

SemReasonerException

IOException

evaluateConnectors

public void evaluateConnectors()
                        throws InterruptedException,
SemReasonerException,
IOException

Throws:

InterruptedException

SemReasonerException

IOException