|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
de.bsvrz.pua.prot.manager.taskmanager.ThreadElement
public class ThreadElement
Thread der einen Auftrag der in den Berecih der Protokollerstellung fällt
ausführt. Mögliche Aufträge sind:
- Protokoll erstellen
- Protokoll abbrechen
- Status der Protokollerstellung anfordern
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
static byte |
INVALID_STATUS
Status der Protokollerstellung nicht ermittelbar. |
boolean |
running
Zeigt an, ob der Thread bereits läuft, d.h. |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
ThreadElement(ThreadPool creator,
DataManagerInterface dataManager,
long maxDelay)
Initialisierung des Objekts |
Method Summary | |
---|---|
void |
abort()
Bricht die Protokollerstellung ab. |
void |
activateCreateProtocol(ClientDavInterface dav,
SystemObject client,
long requestId,
ProcessingParameter pp,
long protocolId)
Startet die Protokollerstellung. |
void |
activateGetProtocol(ClientDavInterface dav,
SystemObject client,
long requestId,
long protocolId)
Startet das Senden eines bereits gespeicherten Protokolls. |
void |
activateGetUnreadProtocol(ClientDavInterface dav,
SystemObject client,
long requestId,
long protocolId)
Startet das Senden eines noch nicht abgerufenen Protokolls. |
protected ProcessingInformation |
evaluateScript()
Evaluiert das Skript. |
long |
getProtocolId()
Liefert die Protokoll-Id. |
long |
getRequestId()
|
Sender |
getSender()
Liefert den Sender, der die Daten für diesen Thread verchickt. |
byte |
getStatus()
Liefert den Status der Protokollerstellung |
void |
kill()
Bricht den Auftrag ab und beendet den Thread vollständig. |
void |
pauseProcessing()
Flußsteuerung: Versand des Protokolls anhalten. |
void |
resumeProcessing()
Flußsteuerung: Versand des Protokolls fortsetzen. |
void |
run()
Startet den Thread und versetzt ihn sofort in einen Schlafzustand, aus dem er erst wieder geweckt wird, wenn eine Anfrage eingeht. |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final byte INVALID_STATUS
public boolean running
run
Methode befindet.
Constructor Detail |
---|
public ThreadElement(ThreadPool creator, DataManagerInterface dataManager, long maxDelay) throws FailureException
creator
- Erzeuger des Threads. Wird benachrichtigt (@link ThreadPool#finished(ThreadElement)}),
sobald Thread unbeschäftigt ist.dataManager
- Data Manager. Ermöglicht das Interpretieren des SkriptsmaxDelay
- Maximale Zeitdauer in ms, für die die Protokollerstellung angehalten werden kann.
FailureException
- Fehler bei der Initialisierung.Method Detail |
---|
public byte getStatus()
INVALID_STATUS
falls kein Protokoll erstellt wird.protected ProcessingInformation evaluateScript() throws FailureException
DataManagerInterface
)
der Skriptinterpreter (Interpreter
) verwendet.
FailureException
- Fehler im Skript.public void abort()
creator
, dass er wieder für
neue Anfragen zur Verfügung steht. Dazu ruft er die Methode ThreadPool.finished(ThreadElement)
auf.
Wird das Protokoll gespeichert auf dem Datenträger gespeichert,
wird es wieder gelöscht.
Im Gegensatz zu kill()
steht der Thread danach weiterhin zur Verfügung.
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public void activateCreateProtocol(ClientDavInterface dav, SystemObject client, long requestId, ProcessingParameter pp, long protocolId) throws FailureException
dav
- Verbindung zum Datenverteilerclient
- AuftraggeberrequestId
- Anfrage-IDpp
- Auftragsparameter.protocolId
- Protokoll-Id
FailureException
- Fehler bei der Sendeanmeldung.public void activateGetProtocol(ClientDavInterface dav, SystemObject client, long requestId, long protocolId) throws FailureException
dav
- Verbindung zum Datenverteiler.client
- Auftraggeber.requestId
- Anfrage-IDprotocolId
- Id des Protokolls, das gesendet werden soll.
FailureException
- Fehler bei der Sendeanmeldung.public void activateGetUnreadProtocol(ClientDavInterface dav, SystemObject client, long requestId, long protocolId) throws FailureException
dav
- Verbindung zum Datenverteiler.client
- Auftraggeber.requestId
- Anfrage-IDprotocolId
- Id des Protokolls, das gesendet werden soll.
FailureException
- Fehler bei der Sendeanmeldung.public void kill()
public long getProtocolId()
public Sender getSender()
null
.public void pauseProcessing()
public void resumeProcessing()
public long getRequestId()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |