org.processmining.stream.core.abstracts

Class AbstractXSRunnableXSWriter<T extends XSDataPacket<?,?>>

java.lang.Object

java.lang.Thread

org.processmining.stream.core.abstracts.AbstractXSRunnable

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

All Implemented Interfaces:

java.lang.Runnable, XSRunnable, XSWriter<T>

Direct Known Subclasses:

AbstractXSAuthor

public abstract class AbstractXSRunnableXSWriter<T extends XSDataPacket<?,?>>
extends AbstractXSRunnable
implements XSWriter<T>

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
AbstractXSRunnableXSWriter(java.lang.String name)

Method Summary

Modifier and Type	Method and Description
void	connect(XSWritable<T> writable) Connect to the XSWritable object
void	disconnect(XSWritable<T> writable) Disconnect from a XSWritable object
long	getNumberOfPacketsSend() Get the total number of packets send so far.
java.util.List<XSWritable<T>>	getWritables() Get all writables to which this writer is currently connected
void	run()
void	write(T dataPacket) Write onto all writable currently connected

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

interrupt, isPaused, isRunning, isStarted, isStopped, pause, pauseXSRunnable, start, startXSRunnable, stopXSRunnable, workPackage

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, stop

Constructor Detail

AbstractXSRunnableXSWriter

public AbstractXSRunnableXSWriter(java.lang.String name)

Method Detail

connect

public void connect(XSWritable<T> writable)

Description copied from interface: XSWriter

Connect to the XSWritable object

Specified by:

connect in interface XSWriter<T extends XSDataPacket<?,?>>

Parameters:

writable - to connect onto

disconnect

public void disconnect(XSWritable<T> writable)

Description copied from interface: XSWriter

Disconnect from a XSWritable object

Specified by:

disconnect in interface XSWriter<T extends XSDataPacket<?,?>>

Parameters:

writable - to disconnect from

write

public void write(T dataPacket)

Description copied from interface: XSWriter

Write onto all writable currently connected

Specified by:

write in interface XSWriter<T extends XSDataPacket<?,?>>

Parameters:

dataPacket - to write

getNumberOfPacketsSend

public long getNumberOfPacketsSend()

Description copied from interface: XSWriter

Get the total number of packets send so far.

Specified by:

getNumberOfPacketsSend in interface XSWriter<T extends XSDataPacket<?,?>>

Returns:

getWritables

public java.util.List<XSWritable<T>> getWritables()

Description copied from interface: XSWriter

Get all writables to which this writer is currently connected

Specified by:

getWritables in interface XSWriter<T extends XSDataPacket<?,?>>

Returns:

the writables

run

public final void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class AbstractXSRunnable