ohmLogger funktioniert, aber drei gleich nicht...

This commit is contained in:
ahren committed 2023-11-21 15:03:17 +01:00
1 parent 1ddb300546
commit 5e3b1b7f20
7 files changed
+81 -86

No files matched your search

+8 -18
View File
@@ -33,19 +33,13 @@ public class Zahlengenerator implements Subscriber<WuerfelData> // Callable
private Wuerfel wuerfel_2;
private Wuerfel wuerfel_3;
public Zahlengenerator()
{
subscriptions = new ArrayList<>();
wertPublisher = new SubmissionPublisher<>();
wuerfel_1 = new Wuerfel(1);
wuerfel_2 = new Wuerfel(2);
wuerfel_3 = new Wuerfel(3);
synchronized(this){
@@ -53,9 +47,6 @@ public class Zahlengenerator implements Subscriber<WuerfelData> // Callable
wuerfel_2.addWertSubscription(this);
wuerfel_3.addWertSubscription(this);
}
}
public void addWertSubscription(Subscriber<WuerfelData> subscriber)
@@ -70,9 +61,6 @@ public class Zahlengenerator implements Subscriber<WuerfelData> // Callable
wuerfel_1.start();
wuerfel_2.start();
wuerfel_3.start();
}
public void stop()
@@ -82,22 +70,24 @@ public class Zahlengenerator implements Subscriber<WuerfelData> // Callable
wuerfel_1.stop();
wuerfel_2.stop();
wuerfel_3.stop();
if (wuerfel_1.getValue() == wuerfel_2.getValue() && wuerfel_2.getValue() == wuerfel_3.getValue()){
lg.warning("This user has to much luck, he/she should go to a casino");
}
else
lg.warning("unlucky" + wuerfel_1.getValue() + wuerfel_2.getValue() + wuerfel_3.getValue());
}
@Override
public void onSubscribe(Flow.Subscription subscription) {
lg.info("on subscribe");
lg.config("on subscribe");
this.subscriptions.add(subscription);
subscription.request(1);
}
@Override
public void onNext(WuerfelData item) {
lg.info("on Next");
lg.config("on Next");
this.wertPublisher.submit(item);
this.subscriptions.get(item.getId() - 1).request(1);
}