|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.bsvrz.pua.prot.manager.taskmanager.ThreadPool
public class ThreadPool
Verwaltet eine feste Anzahl von ThreadElement
Objekten.
Diese Threads werden über die Protokoll-Id identifiziert.
ThreadPool führt eine Liste mi
ThreadGroup
kann nicht verwendet werden, da die Anzahl der Threads
nicht eingestellt werden kann.
Außerdem führt ThreadPool eine Liste mit ausstehenden Aufträgen, die auf einen
frei werdenen Thread verteilt werden.
Constructor Summary | |
---|---|
ThreadPool(ClientDavInterface dav,
int maxProtocols,
DataManagerInterface dataManager,
int maxQueries,
long maxDelay,
ConfigurationObject configAuth)
Erzeugt den ThreadPool. |
Method Summary | |
---|---|
int |
alive()
|
boolean |
busy()
Zeigt an ob weitere Anfragen angenommen werden können. |
java.lang.Long[] |
getActiveProtocols()
Liste mit den Protokollen die gerade gesendet / erstellt werden. |
ConfigurationObject |
getCofigAuth()
|
ThreadElement |
getThread(long protocolId)
Liefert den aktiven Thread mit der gegebenen Protokoll-Id zurück. |
java.lang.Long[][] |
getWaitingProtocols()
Liste mit den Anfrage-Ids und zugehörigen Protokoll-Ids, die momentan in der Warteschlange liegen.Falls keine werte vorliegen, wird ein Feld der Länge 0 zurückgegeben. |
boolean |
isTerminated()
Zeigt an ob alle Threads beendet wurden. |
void |
killAll()
Bricht alle Aufträge ab und beendet alle Threads. |
boolean |
storeCreateQuery(long requestId,
ProcessingParameter pp,
SystemObject client,
long protocolId)
Legt einen Auftrag zur Protokollerstellung in der Warteschlange ab. |
boolean |
storeGetProtocolQuery(long requestId,
SystemObject client,
long protocolId)
Legt einen Auftrag zum ausgeben eines gespeicherten Protokolls in der Warteschlange ab. |
boolean |
storeGetUnreadProtocolQuery(long requestId,
SystemObject client,
long protocolId)
Legt einen Auftrag zum ausgeben eines noch nicht abgelegten Protokolls in der Warteschlange ab. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ThreadPool(ClientDavInterface dav, int maxProtocols, DataManagerInterface dataManager, int maxQueries, long maxDelay, ConfigurationObject configAuth) throws FailureException
dav
- maxProtocols
- Anzahl der Threads die gleichzeitig laufen dürfendataManager
- Datenmanager. Ermöglicht das Interpretieren des Skripts.maxQueries
- Maximale Größe der Warteschlange für Anufträge zur Protokollerstellung.maxDelay
- Maximale Zeitdauer in ms, für die die Protokollerstellung angehalten werden kann.configAuth
- Konfigurationsverantwortlicher für Anfragen an das Archivsystem.
FailureException
- Keine Verbindung zum Datenverteiler; Erzeugen aller Threads scheitert.Method Detail |
---|
public boolean busy()
true
falls die Warteschlange bereits voll ist. false
sonst.public void killAll()
isTerminated()
überprüft werden, ob die Threads
beendet wurden.
public int alive()
public ConfigurationObject getCofigAuth()
public boolean storeCreateQuery(long requestId, ProcessingParameter pp, SystemObject client, long protocolId) throws FailureException
requestId
- Anfrage-Id. Id, die die anfragende Applikation vergeben hat.pp
- Auftragsparameterclient
- Auftraggeber, an den das Ergebnis gesendet wird.protocolId
- Protokoll-Id
true
falls der Auftrag angenommen wurde.
FailureException
- Fehler beim Senden.public boolean storeGetProtocolQuery(long requestId, SystemObject client, long protocolId) throws FailureException
requestId
- Anfrage-Id. Id, die die anfragende Applikation vergeben hat.client
- Auftraggeber, an den das Ergebnis gesendet wird.protocolId
- Protokoll-Id des Protokolls, das abgerufen werden soll.
true
falls der Auftrag angenommen wurde.
FailureException
- Fehler beim Senden.public boolean storeGetUnreadProtocolQuery(long requestId, SystemObject client, long protocolId) throws FailureException
requestId
- Anfrage-Id. Id, die die anfragende Applikation vergeben hat.client
- Auftraggeber, an den das Ergebnis gesendet wird.protocolId
- Protokoll-Id des Protokolls, das abgerufen werden soll.
true
falls der Auftrag angenommen wurde.
FailureException
- Fehler beim Senden.public java.lang.Long[] getActiveProtocols()
public java.lang.Long[][] getWaitingProtocols()
public ThreadElement getThread(long protocolId)
protocolId
- Protokoll-Id des gesuchten Threads
public boolean isTerminated()
true
falls alle Threads beendet wurden.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |