Package com.streambase.sb.operator

Class Operator.OperatorThread

java.lang.Object

java.lang.Thread

com.streambase.sb.operator.Operator.OperatorThread

All Implemented Interfaces:

Runnable

Enclosing class:

Operator

public class Operator.OperatorThread
extends Thread

The thread that wraps an operator runnable

Nested Class Summary

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method	Description
void	run()	Run method of this operator thread.
boolean	shouldRun()	Implement state request responses of this operator thread.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

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

Method Details

run

public void run()

Run method of this operator thread. This starts the operator runnable's run method and, upon exit, either accepts the SHUTDOWN state request, or goes silently.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

shouldRun

public boolean shouldRun()

Implement state request responses of this operator thread.

Returns:

true to run, false otherwise