Class StandardContainerDirWalk
java.lang.Object
de.bsvrz.ars.ars.persistence.walk.internal.StandardContainerDirWalk
- All Implemented Interfaces:
DataIdentificationDirWalk
public class StandardContainerDirWalk extends java.lang.Object implements DataIdentificationDirWalk
Standardimplementierung eines ContainerDirWalk
-
Constructor Summary
Constructors Constructor Description StandardContainerDirWalk(DataIdentificationDirGetter contGetter)Erstellt einen neuen StandardContainerDirWalk -
Method Summary
Modifier and Type Method Description <E> java.util.stream.Stream<E>collect(java.lang.String actionName, int numThreads, DataIdentificationDirCollector<E> collector)Führt den Verzeichnisdurchlauf aus.voidexecute(java.lang.String actionName, int numThreads, DataIdentificationDirAction action)Führt den Verzeichnisdurchlauf aus.LongTermTaskStatePublisher.TaskgetPublisherTask()java.time.DurationgetStatusInterval()Gibt das Intervall zurück, in dem Statusmeldungen ausgegeben werden (positiv)StatusPrintergetStatusPrinter()Gibt die Klasse zurück, die Statusmeldungen ausgibt.voidincreaseContCount(int increment)Inkrementiert die Anzahl besuchter Container (interne Methode, die vonContainerWalkaufgerufen wird, damit diese Klasse die Anzahl Container für die Ausgabe mit-zählen kann)voidsetPublisherTask(LongTermTaskStatePublisher.Task publisherTask)voidsetStatusInterval(java.time.Duration statusInterval)Setzt das StatusintervallvoidsetStatusPrinter(StatusPrinter statusPrinter)Setzt die Klasse, die Statusmeldungen schreibt.voidterminate()Sorgt für ein sofortiges, aber kontrolliertes Beenden.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Constructor Details
-
StandardContainerDirWalk
Erstellt einen neuen StandardContainerDirWalk- Parameters:
contGetter- Klasse, die Cotnainerverzeichnisse auflistet.
-
-
Method Details
-
getStatusInterval
public java.time.Duration getStatusInterval()Description copied from interface:DataIdentificationDirWalkGibt das Intervall zurück, in dem Statusmeldungen ausgegeben werden (positiv)- Specified by:
getStatusIntervalin interfaceDataIdentificationDirWalk- Returns:
- das Intervall
-
setStatusInterval
public void setStatusInterval(java.time.Duration statusInterval)Description copied from interface:DataIdentificationDirWalkSetzt das Statusintervall- Specified by:
setStatusIntervalin interfaceDataIdentificationDirWalk- Parameters:
statusInterval- Intervall
-
getStatusPrinter
Description copied from interface:DataIdentificationDirWalkGibt die Klasse zurück, die Statusmeldungen ausgibt.- Specified by:
getStatusPrinterin interfaceDataIdentificationDirWalk- Returns:
- Klasse
-
setStatusPrinter
Description copied from interface:DataIdentificationDirWalkSetzt die Klasse, die Statusmeldungen schreibt.- Specified by:
setStatusPrinterin interfaceDataIdentificationDirWalk- Parameters:
statusPrinter- Beliebige Subklasse/Instanz vonStatusPrinter
-
getPublisherTask
- Specified by:
getPublisherTaskin interfaceDataIdentificationDirWalk
-
setPublisherTask
- Specified by:
setPublisherTaskin interfaceDataIdentificationDirWalk
-
execute
public void execute(java.lang.String actionName, int numThreads, DataIdentificationDirAction action) throws PersistenceExceptionDescription copied from interface:DataIdentificationDirWalkFührt den Verzeichnisdurchlauf aus. Jedes ContainerDirWalk-Objekt kann nur einmal benutzt werden.- Specified by:
executein interfaceDataIdentificationDirWalk- Parameters:
actionName- Name (zur Benennung der Thread-Objekte, Ausgabe in Debug-Meldungen usw.)numThreads- Anzahl Threads zur Bearbeitungaction- Durchzuführende Aktion- Throws:
PersistenceException- Falls ein Fehler Auftritt
-
collect
public <E> java.util.stream.Stream<E> collect(java.lang.String actionName, int numThreads, DataIdentificationDirCollector<E> collector) throws PersistenceExceptionDescription copied from interface:DataIdentificationDirWalkFührt den Verzeichnisdurchlauf aus. Jedes ContainerDirWalk-Objekt kann nur einmal benutzt werden.- Specified by:
collectin interfaceDataIdentificationDirWalk- Type Parameters:
E- Ergebnistyp, der gesammelt werden soll.- Parameters:
actionName- Name (zur Benennung der Thread-Objekte, Ausgabe in Debug-Meldungen usw.)numThreads- Anzahl Threads zur Bearbeitungcollector- Ausdruck, der für jedes Verzeichnis ausgeführt wurd und ein Ergebnis zurückliefert- Returns:
- Gefundene Objekte
- Throws:
PersistenceException- Falls ein Fehler Auftritt
-
terminate
public void terminate()Description copied from interface:DataIdentificationDirWalkSorgt für ein sofortiges, aber kontrolliertes Beenden. Der aktuelle Verzeichnisdurchlauf je Thread wird abgeschlossen.- Specified by:
terminatein interfaceDataIdentificationDirWalk
-
increaseContCount
public void increaseContCount(int increment)Description copied from interface:DataIdentificationDirWalkInkrementiert die Anzahl besuchter Container (interne Methode, die vonContainerWalkaufgerufen wird, damit diese Klasse die Anzahl Container für die Ausgabe mit-zählen kann)- Specified by:
increaseContCountin interfaceDataIdentificationDirWalk- Parameters:
increment- Anzahl, um die inkrementiert werden soll
-