Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
 schuhmannje82308
|
5f9230815a | ||
|
schuhmannje82308
|
7406d7cdd3 | ||
 ahren
|
dc4291d47a | ||
|
ahren
|
5f5bceb3b8 | ||
|
ahren
|
61e101b877 | ||
|
ahren
|
03251b36f5 | ||
|
schuhmannje82308
|
4705e399f9 | ||
|
schuhmannje82308
|
1aaabfe73e | ||
|
schuhmannje82308
|
964fc35834 | ||
|
ahren
|
6d20c28e4f | ||
|
ahren
|
5e3b1b7f20 | ||
|
ahren
|
1ddb300546 | ||
|
schuhmannje82308
|
13483d909c | ||
|
schuhmannje82308
|
50deb6c1c9 | ||
|
schuhmannje82308
|
5be14364fd |
@@ -0,0 +1,145 @@
|
||||
| 2023-11-28T12:09:28.433757500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:28.469713800 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:29.699390 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:29.701067600 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:29.711254700 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 114 |
|
||||
| 2023-11-28T12:09:30.747813900 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:30.748532600 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:32.605015500 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:32.606067700 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:32.606712600 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 556 |
|
||||
| 2023-11-28T12:09:33.499366900 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:33.499366900 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:33.501063400 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 556 |
|
||||
| 2023-11-28T12:09:34.504396 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:34.505430200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:35.513390700 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:35.513390700 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:35.513390700 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 544 |
|
||||
| 2023-11-28T12:09:36.521840500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:36.521840500 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:37.197352 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:37.198350200 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:37.198679400 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 511 |
|
||||
| 2023-11-28T12:09:38.246307900 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:38.246307900 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:39.348837600 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:39.389536200 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:39.389536200 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 242 |
|
||||
| 2023-11-28T12:09:40.706097800 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:40.751600800 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:41.679364 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:41.679364 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:41.680620100 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 466 |
|
||||
| 2023-11-28T12:09:42.768099300 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:42.768099300 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:43.682658600 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:43.682658600 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:43.683945800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 465 |
|
||||
| 2023-11-28T12:09:44.651421 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:09:44.651421 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:09:46.762910100 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:09:46.762910100 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:09:46.764158200 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 441 |
|
||||
| 2023-11-28T12:10:46.087069900 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:46.088630900 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:51.139050200 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:51.139050200 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:51.147505800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:51.694431600 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:51.694431600 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:51.695173900 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:52.518216 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:52.520450500 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:52.521119 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:52.727710800 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:52.727710800 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:52.728462800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:52.923203200 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:52.924766600 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:52.925372800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:53.119851300 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:53.119851300 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:53.120847700 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:53.328334 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:53.328334 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:53.329263600 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:53.546927100 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:53.546927100 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:53.553801700 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:53.776855500 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:53.776855500 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:53.778044800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:53.982088200 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:53.990924100 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:53.991478500 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:54.208730700 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:54.209743200 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:54.210143200 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:54.402328200 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:54.402328200 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:54.403326800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:54.611448500 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:54.611448500 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:54.611448500 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:54.813837400 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:54.814194800 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:54.815035500 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:55.037588300 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:55.037588300 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:55.038388500 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:55.561208500 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:55.562162100 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:55.562528800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:55.778646800 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:10:55.778646800 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:10:55.778646800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 266 |
|
||||
| 2023-11-28T12:10:56.939211600 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:56.939211600 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:58.174780800 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:58.175767100 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:58.855601400 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:58.858727 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:59.057981100 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:59.057981100 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:59.254540200 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:59.254540200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:59.432098500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:59.439079300 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:59.620527100 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:59.621538200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:10:59.802782700 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:10:59.802782700 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.004424 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.005424200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.183865700 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.183865700 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.371096500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.371096500 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.565349300 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.566358500 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.735101700 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.735101700 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:00.925614500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:00.925614500 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:01.114057500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:01.114057500 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:01.301556600 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:01.301556600 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:01.486965200 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:01.486965200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:01.681669 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:01.681669 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:01.879019 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:01.879019 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:02.080826800 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:02.081886800 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:02.285759200 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:02.285759200 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:02.509117500 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:02.510126 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:02.710700200 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T12:11:02.711687300 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T12:11:03.785108700 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T12:11:03.785108700 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T12:11:03.785108700 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 215 |
|
||||
@@ -0,0 +1,15 @@
|
||||
| 2023-11-28T11:37:42.390252 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T11:37:42.393278400 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T11:37:43.136932500 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T11:37:43.137930 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T11:37:43.143407 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 522 |
|
||||
| 2023-11-28T11:38:59.188169300 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T11:38:59.189224300 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T11:39:00.790984600 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T11:39:00.791922600 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T11:39:00.800778 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 463 |
|
||||
| 2023-11-28T11:39:02.989252600 | INFO | bandit.Schnittstelle.StartStopController | Start gedruekt |
|
||||
| 2023-11-28T11:39:02.990717700 | INFO | bandit.Model.Zahlengenerator | Generator gestartet |
|
||||
| 2023-11-28T11:39:04.198394300 | INFO | bandit.Schnittstelle.StartStopController | Stop gedrueckt |
|
||||
| 2023-11-28T11:39:04.214775 | INFO | bandit.Model.Zahlengenerator | Generator gestopt |
|
||||
| 2023-11-28T11:39:04.215990800 | WARNING | bandit.Model.Zahlengenerator | unlucky -> 544 |
|
||||
@@ -1,114 +0,0 @@
|
||||
/*
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
||||
*/
|
||||
|
||||
package bandit.Model.Generator;
|
||||
|
||||
import bandit.Model.Zahlengenerator;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.Flow.Subscriber;
|
||||
import java.util.concurrent.SubmissionPublisher;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
import java.util.logging.Logger;
|
||||
import bandit.util.OhmLogger;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
*/
|
||||
public class Generator2 implements Runnable // Callable
|
||||
{
|
||||
private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen
|
||||
|
||||
private Integer[] wert;
|
||||
private volatile boolean laufend;
|
||||
private ExecutorService eService;
|
||||
|
||||
private final Object LOCK;
|
||||
|
||||
private SubmissionPublisher<Integer[]> wertPublisher;
|
||||
|
||||
public Generator2(Zahlengenerator hauptgenerator)
|
||||
{
|
||||
wert = new Integer[2];
|
||||
wert[0] = -1;
|
||||
wert[1] = 2;
|
||||
|
||||
laufend = false;
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
wertPublisher = new SubmissionPublisher<>();
|
||||
this.addWertSubscription(hauptgenerator);
|
||||
LOCK = new Object();
|
||||
}
|
||||
|
||||
public void addWertSubscription(Subscriber<Integer[]> subscriber)
|
||||
{
|
||||
wertPublisher.subscribe(subscriber);
|
||||
}
|
||||
|
||||
public void start()
|
||||
{
|
||||
laufend = true;
|
||||
synchronized (LOCK)
|
||||
{
|
||||
LOCK.notifyAll();
|
||||
}
|
||||
|
||||
|
||||
if (eService.isShutdown())
|
||||
{
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
}
|
||||
eService.execute(this);
|
||||
}
|
||||
|
||||
public void stop()
|
||||
{
|
||||
synchronized(LOCK){
|
||||
laufend = false;
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
while (true)
|
||||
{
|
||||
while (!laufend)
|
||||
{
|
||||
synchronized (LOCK)
|
||||
{
|
||||
try
|
||||
{
|
||||
lg.info("WAIT_Gen2");
|
||||
LOCK.wait();
|
||||
}
|
||||
catch (InterruptedException ex)
|
||||
{
|
||||
lg.warning(ex.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
Thread.sleep(100);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
System.err.println(ex);
|
||||
}
|
||||
this.berechneWert();
|
||||
wertPublisher.submit(wert);
|
||||
}
|
||||
}
|
||||
|
||||
private synchronized void berechneWert()
|
||||
{
|
||||
wert[0] = (int) (1 + 6*Math.random());
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -1,114 +0,0 @@
|
||||
/*
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
||||
*/
|
||||
|
||||
package bandit.Model.Generator;
|
||||
|
||||
import bandit.Model.Zahlengenerator;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.Flow.Subscriber;
|
||||
import java.util.concurrent.SubmissionPublisher;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
import java.util.logging.Logger;
|
||||
import bandit.util.OhmLogger;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
*/
|
||||
public class Generator3 implements Runnable // Callable
|
||||
{
|
||||
private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen
|
||||
|
||||
private Integer[] wert;
|
||||
private volatile boolean laufend;
|
||||
private ExecutorService eService;
|
||||
|
||||
private final Object LOCK;
|
||||
|
||||
private SubmissionPublisher<Integer[]> wertPublisher;
|
||||
|
||||
public Generator3(Zahlengenerator hauptgenerator)
|
||||
{
|
||||
wert = new Integer[2];
|
||||
wert[0] = -1;
|
||||
wert[1] = 3;
|
||||
|
||||
laufend = false;
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
wertPublisher = new SubmissionPublisher<>();
|
||||
this.addWertSubscription(hauptgenerator);
|
||||
LOCK = new Object();
|
||||
}
|
||||
|
||||
public void addWertSubscription(Subscriber<Integer[]> subscriber)
|
||||
{
|
||||
wertPublisher.subscribe(subscriber);
|
||||
}
|
||||
|
||||
public void start()
|
||||
{
|
||||
laufend = true;
|
||||
synchronized (LOCK)
|
||||
{
|
||||
LOCK.notifyAll();
|
||||
}
|
||||
|
||||
|
||||
if (eService.isShutdown())
|
||||
{
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
}
|
||||
eService.execute(this);
|
||||
}
|
||||
|
||||
public void stop()
|
||||
{
|
||||
synchronized(LOCK){
|
||||
laufend = false;
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
while (true)
|
||||
{
|
||||
while (!laufend)
|
||||
{
|
||||
synchronized (LOCK)
|
||||
{
|
||||
try
|
||||
{
|
||||
lg.info("WAIT_Gen3");
|
||||
LOCK.wait();
|
||||
}
|
||||
catch (InterruptedException ex)
|
||||
{
|
||||
lg.warning(ex.toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
Thread.sleep(100);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
System.err.println(ex);
|
||||
}
|
||||
this.berechneWert();
|
||||
wertPublisher.submit(wert);
|
||||
}
|
||||
}
|
||||
|
||||
private synchronized void berechneWert()
|
||||
{
|
||||
wert[0] = (int) (1 + 6*Math.random());
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -3,70 +3,63 @@
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
||||
*/
|
||||
|
||||
package bandit.Model.Generator;
|
||||
package bandit.Model;
|
||||
|
||||
import bandit.Model.Zahlengenerator;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.Flow.Subscriber;
|
||||
import java.util.concurrent.SubmissionPublisher;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
import java.util.logging.Logger;
|
||||
import bandit.util.OhmLogger;
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
* @author Schuhmann
|
||||
*/
|
||||
public class Generator1 implements Runnable // Callable
|
||||
public class Wuerfel implements Runnable // Callable
|
||||
{
|
||||
private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen
|
||||
|
||||
private Integer[] wert;
|
||||
private WuerfelData data;
|
||||
private volatile boolean laufend;
|
||||
private ExecutorService eService;
|
||||
|
||||
private final Object LOCK;
|
||||
private SubmissionPublisher<WuerfelData> wertPublisher;
|
||||
|
||||
private SubmissionPublisher<Integer[]> wertPublisher;
|
||||
|
||||
public Generator1(Zahlengenerator hauptgenerator)
|
||||
public Wuerfel(int id)
|
||||
{
|
||||
wert = new Integer[2];
|
||||
wert[0] = -1;
|
||||
wert[1] = 1;
|
||||
|
||||
data = new WuerfelData(id, 0);
|
||||
laufend = false;
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
eService = null;
|
||||
wertPublisher = new SubmissionPublisher<>();
|
||||
this.addWertSubscription(hauptgenerator);
|
||||
LOCK = new Object();
|
||||
}
|
||||
|
||||
public void addWertSubscription(Subscriber<Integer[]> subscriber)
|
||||
public void addWertSubscription(Subscriber<WuerfelData> subscriber)
|
||||
{
|
||||
wertPublisher.subscribe(subscriber);
|
||||
}
|
||||
|
||||
public void start()
|
||||
{
|
||||
synchronized (this) {
|
||||
laufend = true;
|
||||
}
|
||||
|
||||
if (eService == null)
|
||||
{
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
eService.execute(this);
|
||||
}
|
||||
synchronized (LOCK)
|
||||
{
|
||||
LOCK.notifyAll();
|
||||
}
|
||||
|
||||
|
||||
if (eService.isShutdown())
|
||||
{
|
||||
eService = Executors.newSingleThreadExecutor();
|
||||
}
|
||||
eService.execute(this);
|
||||
}
|
||||
|
||||
public void stop()
|
||||
{
|
||||
synchronized(LOCK){
|
||||
synchronized(this){
|
||||
laufend = false;
|
||||
}
|
||||
}
|
||||
@@ -74,15 +67,17 @@ public class Generator1 implements Runnable // Callable
|
||||
@Override
|
||||
public void run()
|
||||
{
|
||||
lg.fine("Run "+ data.getId());
|
||||
while (true)
|
||||
{
|
||||
|
||||
while (!laufend)
|
||||
{
|
||||
synchronized (LOCK)
|
||||
{
|
||||
try
|
||||
{
|
||||
lg.info("WAIT_Gen1");
|
||||
lg.fine("Stop " + data.getId());
|
||||
LOCK.wait();
|
||||
}
|
||||
catch (InterruptedException ex)
|
||||
@@ -100,15 +95,34 @@ public class Generator1 implements Runnable // Callable
|
||||
{
|
||||
System.err.println(ex);
|
||||
}
|
||||
|
||||
if(laufend){
|
||||
this.berechneWert();
|
||||
wertPublisher.submit(wert);
|
||||
wertPublisher.submit(data);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* berechnet den Wert für jede itteration
|
||||
*/
|
||||
private synchronized void berechneWert()
|
||||
{
|
||||
wert[0] = (int) (1 + 6*Math.random());
|
||||
data.setValue((int) (1 + 6*Math.random()));
|
||||
// if(data.getValue() < 6){
|
||||
// data.setValue(data.getValue()+1);
|
||||
// }
|
||||
// else{
|
||||
// data.setValue(0);
|
||||
//
|
||||
// }
|
||||
|
||||
}
|
||||
|
||||
public synchronized int getValue(){
|
||||
return data.getValue();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
@@ -0,0 +1,44 @@
|
||||
/*
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
||||
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
||||
*/
|
||||
package bandit.Model;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author Js-Sc
|
||||
*/
|
||||
public class WuerfelData {
|
||||
private int id;
|
||||
private int value;
|
||||
|
||||
public WuerfelData(int id, int value){
|
||||
this.id = id;
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return the id
|
||||
*/
|
||||
public int getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @return the value
|
||||
*/
|
||||
public int getValue() {
|
||||
return value;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param value the value to set
|
||||
*/
|
||||
public void setValue(int value) {
|
||||
this.value = value;
|
||||
}
|
||||
|
||||
|
||||
|
||||
}
|
||||
@@ -5,9 +5,8 @@
|
||||
|
||||
package bandit.Model;
|
||||
|
||||
import bandit.Model.Generator.Generator1;
|
||||
import bandit.Model.Generator.Generator2;
|
||||
import bandit.Model.Generator.Generator3;
|
||||
//import bandit.Model.Generator.Generator2;
|
||||
//import bandit.Model.Generator.Generator3;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.Flow.Subscriber;
|
||||
@@ -15,87 +14,88 @@ import java.util.concurrent.SubmissionPublisher;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
import java.util.logging.Logger;
|
||||
import bandit.util.OhmLogger;
|
||||
import java.util.ArrayList;
|
||||
import java.util.concurrent.Flow;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
*/
|
||||
public class Zahlengenerator implements Subscriber<Integer[]> // Callable
|
||||
public class Zahlengenerator implements Subscriber<WuerfelData> // Callable
|
||||
{
|
||||
private static Logger lg = OhmLogger.getLogger(); //Logger sollten immer static sein da sie für alle instanzen loggs ausführen
|
||||
|
||||
private Flow.Subscription subscription;
|
||||
private SubmissionPublisher<Integer[]> wertPublisher;
|
||||
|
||||
private Generator1 generator1;
|
||||
private Thread thd1;
|
||||
|
||||
private Generator2 generator2;
|
||||
private Thread thd2;
|
||||
|
||||
private Generator3 generator3;
|
||||
private Thread thd3;
|
||||
private ArrayList<Flow.Subscription> subscriptions;
|
||||
//private Flow.Subscription subscription;
|
||||
private SubmissionPublisher<WuerfelData> wertPublisher;
|
||||
|
||||
private Wuerfel wuerfel_1;
|
||||
private Wuerfel wuerfel_2;
|
||||
private Wuerfel wuerfel_3;
|
||||
|
||||
public Zahlengenerator()
|
||||
{
|
||||
subscriptions = new ArrayList<>();
|
||||
wertPublisher = new SubmissionPublisher<>();
|
||||
generator1 = new Generator1(this);
|
||||
generator2 = new Generator2(this);
|
||||
generator3 = new Generator3(this);
|
||||
|
||||
wuerfel_1 = new Wuerfel(1);
|
||||
wuerfel_2 = new Wuerfel(2);
|
||||
wuerfel_3 = new Wuerfel(3);
|
||||
|
||||
synchronized(this){
|
||||
wuerfel_1.addWertSubscription(this);
|
||||
wuerfel_2.addWertSubscription(this);
|
||||
wuerfel_3.addWertSubscription(this);
|
||||
}
|
||||
}
|
||||
|
||||
public void addWertSubscription(Subscriber<Integer[]> subscriber)
|
||||
public void addWertSubscription(Subscriber<WuerfelData> subscriber)
|
||||
{
|
||||
wertPublisher.subscribe(subscriber);
|
||||
}
|
||||
|
||||
public void start()
|
||||
{
|
||||
if(thd1==null){
|
||||
thd1 = new Thread(generator1);
|
||||
thd1.start();
|
||||
}
|
||||
if(thd2==null){
|
||||
thd2 = new Thread(generator2);
|
||||
thd2.start();
|
||||
}
|
||||
if(thd3==null){
|
||||
thd3 = new Thread(generator3);
|
||||
thd3.start();
|
||||
}
|
||||
|
||||
generator1.start();
|
||||
generator2.start();
|
||||
generator3.start();
|
||||
|
||||
lg.info("Generator gestartet");
|
||||
|
||||
wuerfel_1.start();
|
||||
wuerfel_2.start();
|
||||
wuerfel_3.start();
|
||||
}
|
||||
|
||||
public void stop()
|
||||
{
|
||||
generator1.stop();
|
||||
generator2.stop();
|
||||
generator3.stop();
|
||||
lg.info("Generator gestopt");
|
||||
|
||||
wuerfel_1.stop();
|
||||
wuerfel_2.stop();
|
||||
wuerfel_3.stop();
|
||||
|
||||
int w1_value = wuerfel_1.getValue();
|
||||
int w2_value = wuerfel_2.getValue();
|
||||
int w3_value = wuerfel_3.getValue();
|
||||
|
||||
|
||||
if (w1_value == w2_value && w2_value == w3_value){
|
||||
lg.warning("This user has to much luck, he/she should go to a casino");
|
||||
}
|
||||
else
|
||||
lg.warning("unlucky -> " + w1_value + w2_value + w3_value);
|
||||
|
||||
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onSubscribe(Flow.Subscription subscription) {
|
||||
this.subscription = subscription;
|
||||
this.subscription.request(1);
|
||||
lg.config("on subscribe");
|
||||
this.subscriptions.add(subscription);
|
||||
subscription.request(1);
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public void onNext(Integer[] item) {
|
||||
public void onNext(WuerfelData item) {
|
||||
lg.config("on Next");
|
||||
this.wertPublisher.submit(item);
|
||||
this.subscription.request(1);
|
||||
this.subscriptions.get(item.getId() - 1).request(1);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -39,12 +39,12 @@ public class StartStopController implements ActionListener
|
||||
{
|
||||
if (evt.getSource() == view.getBtnStart())
|
||||
{
|
||||
lg.info("Start");
|
||||
lg.info("Start gedruekt");
|
||||
model.start();
|
||||
}
|
||||
else
|
||||
{
|
||||
lg.info("Stop");
|
||||
lg.info("Stop gedrueckt");
|
||||
model.stop();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -5,17 +5,20 @@
|
||||
|
||||
package bandit.Schnittstelle;
|
||||
|
||||
import bandit.Model.WuerfelData;
|
||||
import bandit.Model.Zahlengenerator;
|
||||
import bandit.View.ZahlenView;
|
||||
import java.util.ArrayList;
|
||||
import java.util.concurrent.Flow;
|
||||
import java.util.concurrent.Flow.Subscriber;
|
||||
import java.util.concurrent.Flow.Subscription;
|
||||
import javax.swing.Icon;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
*/
|
||||
public class WertAdapter implements Subscriber<Integer[]>
|
||||
public class WertAdapter implements Subscriber<WuerfelData>
|
||||
{
|
||||
private ZahlenView view;
|
||||
private Zahlengenerator model;
|
||||
@@ -35,11 +38,10 @@ public class WertAdapter implements Subscriber<Integer[]>
|
||||
}
|
||||
|
||||
@Override
|
||||
public void onNext(Integer item[])
|
||||
public void onNext(WuerfelData item)
|
||||
{
|
||||
String strWert = String.valueOf(item[0]);
|
||||
|
||||
switch(item[1]){
|
||||
String strWert = String.valueOf(item.getValue());
|
||||
switch(item.getId()){
|
||||
case 1:
|
||||
view.getLblZahl1().setText(strWert);
|
||||
break;
|
||||
@@ -49,9 +51,12 @@ public class WertAdapter implements Subscriber<Integer[]>
|
||||
case 3:
|
||||
view.getLblZahl3().setText(strWert);
|
||||
break;
|
||||
|
||||
}
|
||||
|
||||
|
||||
this.subscription.request(1);
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -70,7 +70,8 @@ public class ZahlenView extends javax.swing.JFrame
|
||||
*/
|
||||
@SuppressWarnings("unchecked")
|
||||
// <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
|
||||
private void initComponents() {
|
||||
private void initComponents()
|
||||
{
|
||||
|
||||
jPanel1 = new javax.swing.JPanel();
|
||||
btnStart = new javax.swing.JButton();
|
||||
|
||||
@@ -5,50 +5,97 @@
|
||||
|
||||
package bandit.util;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.Properties;
|
||||
import java.util.logging.*;
|
||||
|
||||
/**
|
||||
*
|
||||
* @author le
|
||||
* Klasse zur eigens konfigurierten Log-Ausgabe in der Console
|
||||
* @author ahrens
|
||||
*/
|
||||
public class OhmLogger
|
||||
{
|
||||
private static final String LOGGER_NAME = "OhmLogger";
|
||||
private static Logger lg = null;
|
||||
|
||||
private OhmLogger() //Singelton-Patter -> privater ctor -> anlegen nur über klassenmethode möglich
|
||||
/**
|
||||
* privater Konstrukter -> Singleton
|
||||
*/
|
||||
private OhmLogger()
|
||||
{
|
||||
}
|
||||
|
||||
/**
|
||||
* Public Method zum Erstellen des Loggers und zum Aufruf der Methode
|
||||
* zum Initialisieren
|
||||
* @return Referenz auf Logger
|
||||
*/
|
||||
public static Logger getLogger()
|
||||
{
|
||||
if (lg == null)
|
||||
{
|
||||
lg = Logger.getLogger("OhmLogger");
|
||||
lg = Logger.getLogger(LOGGER_NAME);
|
||||
initLogger();
|
||||
}
|
||||
return lg;
|
||||
}
|
||||
|
||||
/**
|
||||
* Methode zum Initialisieren, Suchen der Konfigurationsdatei, Anlegen eines
|
||||
* neuen Console Handlers, Löschen der bisherigen Standard Handler und
|
||||
* Einfügen des eigenen Handler, Setzen des Levels, je nach Properties
|
||||
*/
|
||||
private static void initLogger()
|
||||
{
|
||||
// FileHandler fh = new FileHandler();
|
||||
try (InputStream configFile = OhmLogger.class.getClassLoader().getResourceAsStream("config.properties")) {
|
||||
if (configFile != null) {
|
||||
Properties properties = new Properties();
|
||||
properties.load(configFile);
|
||||
java.util.logging.Level classLogLevel = java.util.logging.Level.parse(properties.getProperty("log.level"));
|
||||
|
||||
ConsoleHandler ch = new ConsoleHandler();
|
||||
ch.setFormatter(new OhmFormatter());
|
||||
lg.setUseParentHandlers(false);
|
||||
lg.getHandlers();
|
||||
lg.addHandler(ch);
|
||||
lg.setLevel(classLogLevel);
|
||||
|
||||
String logDirectory = properties.getProperty("log.directory");
|
||||
String logFileName = properties.getProperty("log.filename");
|
||||
|
||||
FileHandler fileHandler = new FileHandler(logDirectory + "/" + logFileName, true);
|
||||
fileHandler.setFormatter(new OhmFormatter());
|
||||
lg.addHandler(fileHandler);
|
||||
|
||||
} else {
|
||||
System.err.println("Unable to find config.properties file. OhmLogger will use default settings.");
|
||||
}
|
||||
} catch (IOException | SecurityException e) {
|
||||
System.err.println("Error configuring OhmLogger: " + e.getMessage());
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
class OhmFormatter extends SimpleFormatter
|
||||
/**
|
||||
* Klasse zum Setzen des Formates des Auszugebenden Log-Strings
|
||||
* @author ahren
|
||||
*/
|
||||
class OhmFormatter extends Formatter
|
||||
{
|
||||
@Override
|
||||
public String format(LogRecord record)
|
||||
{
|
||||
String logline = "";
|
||||
String logline = "| ";
|
||||
|
||||
LocalDateTime ldt = LocalDateTime.now();
|
||||
logline += ldt.toString();
|
||||
logline += ";" + record.getMessage();
|
||||
logline += "\n";
|
||||
logline += " | " + record.getLevel();
|
||||
logline += " | " + record.getSourceClassName();
|
||||
logline += " | " + record.getMessage();
|
||||
logline += " |\n";
|
||||
|
||||
return logline;
|
||||
}
|
||||
|
||||
@@ -0,0 +1,8 @@
|
||||
log.level=INFO
|
||||
|
||||
log.directory=../Aufgabe7_bandit
|
||||
log.filename=ohmLog
|
||||
|
||||
# Beispiel f\u00fcr verschiedene Level f\u00fcr unterschiedliche Pakete
|
||||
# log.level.bandit.Zahlengenerator=FINE
|
||||
# log.level.bandit.Model.Wuerfel=WARNING
|
||||
Reference in New Issue
Block a user