laufend = true; | laufend = true; | ||||
synchronized (LOCK) | synchronized (LOCK) | ||||
{ | { | ||||
LOCK.notify(); | |||||
LOCK.notifyAll(); | |||||
} | } | ||||
{ | { | ||||
try | try | ||||
{ | { | ||||
lg.info("WAIT"); | |||||
lg.info("WAIT_Gen1"); | |||||
LOCK.wait(); | LOCK.wait(); | ||||
} | } | ||||
catch (InterruptedException ex) | catch (InterruptedException ex) |
laufend = true; | laufend = true; | ||||
synchronized (LOCK) | synchronized (LOCK) | ||||
{ | { | ||||
LOCK.notify(); | |||||
LOCK.notifyAll(); | |||||
} | } | ||||
{ | { | ||||
try | try | ||||
{ | { | ||||
lg.info("WAIT"); | |||||
lg.info("WAIT_Gen2"); | |||||
LOCK.wait(); | LOCK.wait(); | ||||
} | } | ||||
catch (InterruptedException ex) | catch (InterruptedException ex) |
laufend = true; | laufend = true; | ||||
synchronized (LOCK) | synchronized (LOCK) | ||||
{ | { | ||||
LOCK.notify(); | |||||
LOCK.notifyAll(); | |||||
} | } | ||||
{ | { | ||||
try | try | ||||
{ | { | ||||
lg.info("WAIT"); | |||||
lg.info("WAIT_Gen3"); | |||||
LOCK.wait(); | LOCK.wait(); | ||||
} | } | ||||
catch (InterruptedException ex) | catch (InterruptedException ex) |
{ | { | ||||
private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen | private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen | ||||
private int wert; | |||||
private Flow.Subscription subscription; | private Flow.Subscription subscription; | ||||
private SubmissionPublisher<Integer[]> wertPublisher; | private SubmissionPublisher<Integer[]> wertPublisher; | ||||