org.processmining.stream.core.abstracts

Class AbstractXSReader<T extends XSDataPacket<?,?>,S,V>

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable<T>

org.processmining.stream.core.abstracts.AbstractXSReader<T,S,V>

All Implemented Interfaces:

java.lang.Runnable, XSReader<T,S>, XSRunnable, XSStronglyTyped<T>, XSVisualizable, XSWritable<T>

Direct Known Subclasses:

AbstractStaticStreamXSReader

public abstract class AbstractXSReader<T extends XSDataPacket<?,?>,S,V>
extends AbstractXSRunnableXSWritable<T>
implements XSReader<T,S>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AbstractXSReader(java.lang.String name, boolean trackPerformance, XSVisualization<V> visualization)
AbstractXSReader(java.lang.String name, XSVisualization<V> visualization)

Method Summary

Modifier and Type	Method and Description
protected abstract S	computeCurrentResult()
S	getCurrentResult()
XSVisualization<V>	getVisualization()
void	interrupt()
void	pause()
void	pauseXSRunnable() Deprecated.
void	start()
void	startXSRunnable() Deprecated.
void	stopXSRunnable() Deprecated.

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnableXSWritable

deliver, getCommunicationType, getDeliveryLock, getHandlingTimes, getLatestWritingThread, getMemoryUsage, getNextHandlingTimeIndex, getNextMemoryUsageIndex, getNextPacket, getNumberOfPacketsReceived, getPacketHandlingTimes, getPerformanceTrackerStepSize, getUsedMemory, handleNextPacket, isTrackingPerformance, isTrackPerformance, measureUsedMemory, setHandlingTimes, setLatestWritingThread, setMemoryUsage, setNextHandlingTimeIndex, setNextMemoryUsageIndex, setPerformanceTrackerStepSize, setTrackPerformance, storeNewPacket, triggerPacketHandle, workPackage

Methods inherited from class org.processmining.stream.core.abstracts.AbstractXSRunnable

isPaused, isRunning, isStarted, isStopped, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.processmining.stream.core.interfaces.XSRunnable

getName, isPaused, isRunning, isStarted, isStopped, stop

Methods inherited from interface java.lang.Runnable

run

Methods inherited from interface org.processmining.stream.core.interfaces.XSWritable

deliver, getCommunicationType, getDeliveryLock, getNumberOfPacketsReceived, getPacketHandlingTimes, getUsedMemory, isTrackingPerformance, setPerformanceTrackerStepSize, setTrackPerformance, triggerPacketHandle

Methods inherited from interface org.processmining.stream.core.interfaces.XSStronglyTyped

getTopic

Constructor Detail

AbstractXSReader

public AbstractXSReader(java.lang.String name,
                        boolean trackPerformance,
                        XSVisualization<V> visualization)

AbstractXSReader

public AbstractXSReader(java.lang.String name,
                        XSVisualization<V> visualization)

Method Detail

computeCurrentResult

protected abstract S computeCurrentResult()

getCurrentResult

public S getCurrentResult()

Specified by:

getCurrentResult in interface XSReader<T extends XSDataPacket<?,?>,S>

getVisualization

public XSVisualization<V> getVisualization()

Specified by:

getVisualization in interface XSVisualizable

interrupt

public void interrupt()

Specified by:

interrupt in interface XSRunnable

Overrides:

interrupt in class AbstractXSRunnable

pause

public void pause()

Specified by:

pause in interface XSRunnable

Overrides:

pause in class AbstractXSRunnable

pauseXSRunnable

@Deprecated
public void pauseXSRunnable()

Deprecated.

Specified by:

pauseXSRunnable in interface XSRunnable

Overrides:

pauseXSRunnable in class AbstractXSRunnable

start

public void start()

Specified by:

start in interface XSRunnable

Overrides:

start in class AbstractXSRunnable

startXSRunnable

@Deprecated
public void startXSRunnable()

Deprecated.

Specified by:

startXSRunnable in interface XSRunnable

Overrides:

startXSRunnable in class AbstractXSRunnable

stopXSRunnable

@Deprecated
public void stopXSRunnable()

Deprecated.

Specified by:

stopXSRunnable in interface XSRunnable

Overrides:

stopXSRunnable in class AbstractXSRunnable