|
package de.uhilger.avdirektor;
|
|
import java.util.logging.Logger;
|
import java.util.logging.Level;
|
import java.util.List;
|
import java.util.ArrayList;
|
import java.util.Iterator;
|
|
public class MeldeThread extends Thread {
|
|
private static final Logger logger = Logger.getLogger(MeldeThread.class.getName());
|
|
private Process omxplayer;
|
private int exitValue;
|
private List<ProzessLauscher> lauscher = new ArrayList<>();
|
private String meldeUrlStr;
|
|
public void setProcess(Process p) {
|
this.omxplayer = p;
|
}
|
|
public int getExitValue() {
|
return exitValue;
|
}
|
|
public void setMeldeUrl(String meldeUrlStr) {
|
this.meldeUrlStr = meldeUrlStr;
|
}
|
|
public void run() {
|
try {
|
exitValue = omxplayer.waitFor();
|
prozessBeendetMelden();
|
} catch(Exception ex) {
|
logger.log(Level.FINE, ex.getMessage(), ex);
|
} finally {
|
aufraeumen();
|
}
|
}
|
|
private void aufraeumen() {
|
lauscher.clear();
|
lauscher = null;
|
}
|
|
public void lauscherHinzufuegen(ProzessLauscher l) {
|
lauscher.add(l);
|
}
|
|
public void lauscherEntfernen(ProzessLauscher l) {
|
lauscher.remove(l);
|
}
|
|
private void prozessBeendetMelden() {
|
Iterator<ProzessLauscher> i = lauscher.iterator();
|
while(i.hasNext()) {
|
ProzessLauscher l = i.next();
|
l.prozessBeendet(meldeUrlStr);
|
}
|
}
|
|
}
|