Mit der gleichen BlockingQueue in zwei Klassen arbeiten

n01sp

Mitglied
Hey Leute,
ich bin momentan dabei ein kleines Programm zu schreiben und hänge bei der richtigen Übergabe von einer BlockingQueue. Außerdem kann ich meine Threads nicht durch die Methode start() starten.

Java:
package de.sportreporter;

import java.awt.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import sun.misc.Queue;

/**
* Represents a server consuming comments of
* sport reporters, updating the output.
* 
*
*/
public class LiveTicker implements Runnable {
   
    @Override
    public void run() {
        while(true){
            try {
                Thread.sleep(1000);
                BlockingQueue<String> puffer = getEventList();
                System.out.println(puffer);
                puffer.poll();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
       
        }
    }
   
    /**
     * @return returns the list containing the comments
     */
    public synchronized BlockingQueue<String> getEventList() {
        BlockingQueue<String> eventList = new LinkedBlockingQueue<String>();
        return eventList;
    }

    public static void main(String[] args){
        LiveTicker liveTicker = new  LiveTicker();
        SportReporter reporter1 = new SportReporter("München vs. Dortmund", liveTicker.getEventList());
        SportReporter reporter2 = new SportReporter("Berlin vs. Hamburg", liveTicker.getEventList());
        SportReporter reporter3 = new  SportReporter("Stuttgart vs. Köln", liveTicker.getEventList());
        liveTicker.start();
        reporter1.start();
       
   
    }
   
}

Java:
package de.sportreporter;

import java.util.Random;
import java.util.concurrent.BlockingQueue;



/**
* Represents a reporter posting comments of the current match to his
* live ticker.
* 
*
*/
public class SportReporter implements Runnable {
    private final String match;
      BlockingQueue<String> eventList;
     Random random;
   


    /**
     * Sport reporter used for comment a match.
     * @param match name of the match (e.g. names of the playing teams)
     * @param eventList list for posting the comments
     */
    public SportReporter(String match, BlockingQueue<String> eventList) {
        this.match = match;
        this.eventList = eventList;
    }
   
    @Override
    public void run() {
        while (true){
            try {
                Thread.sleep(random.nextInt(6000));
                int pick4 = new Random().nextInt(SoccerEvent.values().length);
                eventList.add(SoccerEvent.values()[pick4].toString());
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }

       
        }
    }

}
Java:
package de.sportreporter;

/**
* Enum class containing all possible football match events.
* 
*
*/
public enum SoccerEvent {
   
    FOUL("Faulspiel"), GOAL("Tor"), OFFSIDE("Abseits"), CORNER("Eckball"), TACKLING("Zweikampf");
   
    private final String catchword;
    SoccerEvent(String catchword){
        this.catchword = catchword;
    }
   
    /**
     * @return returns the German word for the event
     */
    public String getCatchword() {
        return catchword;
    }
}
 

mrBrown

Super-Moderator
Mitarbeiter
getEventList() erstellt bei jedem Aufruf eine neue Queue, jedes Objekt, welche eine erhält, erhält also eine andere, und beim ausgeben wird auch jedes mal der Inhalt einer grad neu erstellten ausgegeben.
Du solltest aus deiner Queue eine Instanzvariable in LiveTicker machen ;)
 

n01sp

Mitglied
Hey , ich glaube ich habe da ein kleine Verständnisproblem. Ist es nicht so dass wenn vor die Deklarierung nichts schreibe , dass es dann automatisch eine INstanzvariable ist und nur wenn static da steht eine Klassenvaribale?
In meinem fall erstelle ich ja 3 mal eine Instanz/Thread vom Typen SportReporte und deshalb erstellt er doch auch nur eine Liste oder sehe ich das faslch?
 

mrBrown

Super-Moderator
Mitarbeiter
Es steht in einer Methode, also ist es nur eine Methodenvariable. Instanz/Klassenvariable ist es nur, wenn es außerhalb einer Methode steht.

Es wird mit jedem Methodenaufruf der Code in der Methode neu ausgeführt, also auch jedes mal mit new ein neues Objekt erstellt, also bekommen alle eine eigene Queue
 

Joose

Top Contributor
Ja du erstellst 3 Objekte der Klasse SportReportert und übergibst diesen im Konstruktor ein Listen Objekt. Das Problem liegt aber wo bzw. wie dieses Listen Objekt erstellt wird.
Es wird nämlich bei jedem Aufruf von getEventList() ein neues Listen Objekt erstellt.

Sprich jedes der SportReporter Objekte hat eine andere Liste, und dein LiveTicker Objekt erzeugt auch immer wieder eine neue Liste.

EDIT:
lokale Variablen: werden innerhalb einer Methode oder eines Blockes deklariert
Instanzvariablen: werden außerhalb von Methoden deklariert
Klassenvariablen: werden außerhalb von Methoden und static deklariert
 

n01sp

Mitglied
Java:
package de.sportreporter;

import java.awt.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import sun.misc.Queue;

/**
* Represents a server consuming comments of
* sport reporters, updating the output.
* 
*
*/
public class LiveTicker extends Thread {
    BlockingQueue<String> eventList = new LinkedBlockingQueue<String>();
    @Override
    public void run() {
        while(true){
            try {
                Thread.sleep(1000);
                BlockingQueue<String> puffer = getEventList();
                System.out.println(puffer);
                puffer.poll();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
      
        }
    }
  
    /**
     * @return returns the list containing the comments
     */
    public synchronized BlockingQueue<String> getEventList() {
      
        return eventList;
    }

    public static void main(String[] args){
        LiveTicker liveTicker = new  LiveTicker();
        SportReporter reporter1 = new SportReporter("München vs. Dortmund", liveTicker.getEventList());
        SportReporter reporter2 = new SportReporter("Berlin vs. Hamburg", liveTicker.getEventList());
        SportReporter reporter3 = new  SportReporter("Stuttgart vs. Köln", liveTicker.getEventList());
        liveTicker.start();
        reporter1.start();

So wäre die Queue ja jetzt eine Instanzvariable, das Problem ist nur wie benutze ich denn die gleiche in der Klasse SportReporter? Ich dachte eigentlich wenn ich einen Sportreporter erzeuge, dass die klasse dann automatisch damit arbeitet scheint abe rnicht ganz zu funktionieren.
 

Joose

Top Contributor
...das Problem ist nur wie benutze ich denn die gleiche in der Klasse SportReporter?
Das hast du doch schon erledigt: getEventList liefert dir deine Queue zurück, und jedem deiner SportReporter Objekte übergibst du ja dieses Liste
Ich dachte eigentlich wenn ich einen Sportreporter erzeuge, dass die klasse dann automatisch damit arbeitet scheint abe rnicht ganz zu funktionieren.
Das Problem ist die Liste wird nirgends initialisiert. Sprich deine SportReporter verweisen auf nichts (null)
Entweder du erstellst einen Konstruktor von LiveTicker und initialisierst dort die Liste oder du erstellst diese beim 1.Aufruf von getEventListe. Ich würde zum Konstruktor raten.

EDIT: Mein Fehler habe die Initialisierung nicht gesehen ;)
 
Zuletzt bearbeitet:

dayaftereh

Top Contributor
Mach mal ein Systemout in der Run Methode vom Sportreporter und deinem Liveticker von der Queue Variable, dann siehst du das die Variable auf die Gleiche Speichernaddresse Zeigt ...

Alle haben jetzt die Queue vom Liveticker, bzw du hast einmal new Queue im Code stehen...
 

n01sp

Mitglied
Java:
package de.sportreporter;

import java.util.Random;
import java.util.concurrent.BlockingQueue;



/**
* Represents a reporter posting comments of the current match to his
* live ticker.
* 
*
*/
public class SportReporter extends Thread {
    public String match;
     public BlockingQueue<String> eventList;
     Random random;
   


    /**
     * Sport reporter used for comment a match.
     * @param match name of the match (e.g. names of the playing teams)
     * @param eventList list for posting the comments
     */
    public SportReporter(String match, BlockingQueue<String> eventList) {
        this.match = match;
        this.eventList = eventList;
    }
   
    @Override
    public void run() {
        while (true){
            int pick = new Random().nextInt(6000);
            try {
                Thread.sleep(pick);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
                int pick4 = new Random().nextInt(SoccerEvent.values().length);
                eventList.add(SoccerEvent.values()[pick4].toString());
           

       
        }
    }

}
Java:
package de.sportreporter;

import java.awt.List;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

import sun.misc.Queue;

/**
* Represents a server consuming comments of
* sport reporters, updating the output.
* 
*
*/
public class LiveTicker extends Thread {
    BlockingQueue<String> eventList = new LinkedBlockingQueue<String>();
   
    public LiveTicker(){
        eventList = new LinkedBlockingQueue<String>();
    }
    @Override
    public void run() {
        while(true){
            if (!eventList.isEmpty()){
            try {
                Thread.sleep(1000);
                System.out.println(eventList.poll());
               
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
       
        }
        }
    }
   
    /**
     * @return returns the list containing the comments
     */
    public synchronized BlockingQueue<String> getEventList() {
       
        return eventList;
    }

    public static void main(String[] args){
        LiveTicker liveTicker = new  LiveTicker();
        SportReporter reporter1 = new SportReporter("München vs. Dortmund", liveTicker.getEventList());
        SportReporter reporter2 = new SportReporter("Berlin vs. Hamburg", liveTicker.getEventList());
        SportReporter reporter3 = new  SportReporter("Stuttgart vs. Köln", liveTicker.getEventList());
        liveTicker.start();
        reporter1.start();
        reporter2.start();
       
   
    }
   
}

So läuft jetzt!
Danke für eure Hilfe! Ihr seid echt Spitze!
Muss nur noch das jeweilige Match übergeben.
 

dayaftereh

Top Contributor
Die if Bedingung im Liveticker für zu einer undeutlich Schleife die 100 % deines cpu nutzt.

Du benötigst den if und Sleep nicht, da Poll bzw take blockiert falls die Queue leer ist. Damit läuft der Thread nicht kontinuierlich....

Warum benutzt du keinen ThreadPool bzw ExecutorService für das Ausführen von deinen Sportreportern? Vorsichtig gesagt wäre das Software technisch die sauberere Lösung?
 

Joose

Top Contributor
Die if Bedingung im Liveticker für zu einer undeutlich Schleife die 100 % deines cpu nutzt.
Dem kann ich nur zustimmen. Anstatt eines while(true) solltest du eine echte/richtige Abbruchbedingung verwenden!

Du benötigst den if und Sleep nicht, da Poll bzw take blockiert falls die Queue leer ist. Damit läuft der Thread nicht kontinuierlich....

Warum benutzt du keinen ThreadPool bzw ExecutorService für das Ausführen von deinen Sportreportern? Vorsichtig gesagt wäre das Software technisch die sauberere Lösung?
Stimmt, das sleep(...) ist unnötig, aber auch ohne ThreadPool oder ExecutorService kann man das Programm "sauber" ausführen lassen.
 

dayaftereh

Top Contributor
Deswegen habe ich auch Vorsichtig im Satz und spreche von der Software technischen Seite. Natürlich kann man das Programm sauber ausführen, wobei es nicht beendet ;) .

@Joose
Aber ein ExecutorService ist ja ne Queue mit Aufgabe oder nicht, wobei du die Queue und die zuabarbeiten Threads nicht implementieren musst ?
 

n01sp

Mitglied
Das sleep ist in der methode drin weil eine Sekunde zwischen Kommentar in der Liste erstellen und ausgeben auf der Konsole sein soll.
 
Ähnliche Java Themen
  Titel Forum Antworten Datum
Glühlampe Usereingabe in der gleichen Zeile ausgeben Java Basics - Anfänger-Themen 6
I 2 verschiedene Klassen mit gleichen Property vergleichen Java Basics - Anfänger-Themen 13
I Entity Objekt nicht gefunden -> Webhook empfangen in der gleichen Methode (Transaktion) Java Basics - Anfänger-Themen 37
N Verschiedene Konstruktoren mit gleichen Datentypen Java Basics - Anfänger-Themen 8
I JPA / Hibernate "Predicate" kombinieren in der gleichen Query Java Basics - Anfänger-Themen 1
sondr Anzahl der gleichen Positionen im Array Java Basics - Anfänger-Themen 3
E Best Practice Konstruktor mit bestehender Intanz der gleichen Klasse aufrufen Java Basics - Anfänger-Themen 4
J Erhöhen eines Values als Integer bei gleichen Keys in HashMap Java Basics - Anfänger-Themen 12
O Array nach gleichen Zahlen prüfen und ausgeben Java Basics - Anfänger-Themen 6
D Liste nach 2 gleichen Einträgen suchen Java Basics - Anfänger-Themen 4
L Eine Klasse aus dem gleichen Package starten Java Basics - Anfänger-Themen 3
B Datentypen Datentyp welcher den gleichen Namen wie die Klasse trägt? Java Basics - Anfänger-Themen 1
N Objektvariablen haben den gleichen Wert - warum? Java Basics - Anfänger-Themen 5
AssELAss Datums-Objekt prüfen ob im gleichen Monat? Java Basics - Anfänger-Themen 5
V Anzahl von gleichen Werten in einem Int-Array ermitteln Java Basics - Anfänger-Themen 4
T Classpath Datei an dem gleichen Ort speichern Java Basics - Anfänger-Themen 9
L Array - Nach 2 gleichen Werten stoppen Java Basics - Anfänger-Themen 5
J Zweimal im gleichen Paint-Fenster malen Java Basics - Anfänger-Themen 8
T List mit mehreren gleichen Strings bereinigen Java Basics - Anfänger-Themen 4
S Strings und Binärdaten aus der gleichen Datei auslesen Java Basics - Anfänger-Themen 24
A Datei Lesen und Schreiben in gleichen Klasse Java Basics - Anfänger-Themen 3
C Objekt von Klasse im gleichen Paket erzeugen Java Basics - Anfänger-Themen 8
2 Hashmap mit gleichen Schlüsseln? Java Basics - Anfänger-Themen 3
A Stilfrage: statische Variable mit Instanz der gleichen Klasse Java Basics - Anfänger-Themen 8
B Class wird nicht gefunde obwohl sie im gleichen Ordner liegt Java Basics - Anfänger-Themen 8
G Interfaces mit gleichen Methoden Java Basics - Anfänger-Themen 4
J Verschiedene Ausgaben bei gleichen Ausdrücken (Typecasting?) Java Basics - Anfänger-Themen 5
M mehreren klassen die gleichen funktionen bereitstellen? Java Basics - Anfänger-Themen 3
T 2D Array nach gleichen Werten durchsuchen Java Basics - Anfänger-Themen 6
S DAY_OF_WEEK liefert immer gleichen Wert Java Basics - Anfänger-Themen 6
F Java BlockingQueue Java Basics - Anfänger-Themen 7
Torschti Eingabe von Dezimalzahlen (bis zu zwei Kommastellen) Java Basics - Anfänger-Themen 11
A 1 Leerzeichen durch zwei Leerzeichen ersetzen Java Basics - Anfänger-Themen 4
K Warum wird mir hier nach dem ersten Durchlauf zwei mal "welchen Datentyp wollen sie übergeben?" ausgegeben ? Java Basics - Anfänger-Themen 1
sasnitzer java augensumme von zwei würfeln ist 1 Java Basics - Anfänger-Themen 8
krgewb Double mit zwei Nachkommastellen Java Basics - Anfänger-Themen 2
Distanz zwischen zwei Zeichenfolgen in einem String bestimmen Java Basics - Anfänger-Themen 5
D Größtes Palindrom Produkt aus zwei dreistelligen Zahlen Java Basics - Anfänger-Themen 60
berserkerdq2 Habe zwei exceptions, welche ist ein Kommunikationsfehler und welche ein Ausgabefehler? Java Basics - Anfänger-Themen 4
berserkerdq2 Zwei Klassen Erben von der Klasse A, die eine Klasse kann ich an Methoden übergeben, die als Parameter A haben, die andere nicht? Java Basics - Anfänger-Themen 3
B Erste Schritte Bisektion mit zwei Funktionen? Java Basics - Anfänger-Themen 1
G zwei Instanzen einer Klasse Java Basics - Anfänger-Themen 29
A Java-XSSFBook: zwei Sheets mergen Java Basics - Anfänger-Themen 5
C Zwei Arrays addieren und ausgeben Java Basics - Anfänger-Themen 3
J Speichern von zwei Variablen durch Auslesen aus einem Numberfield Java Basics - Anfänger-Themen 2
D Zwei verschiedene Intellij Projekte, wie benutze ich wechselseitig objekte Java Basics - Anfänger-Themen 8
berserkerdq2 Wie würde man einen regulären Ausdruck in Java schreiben, der prüft, dass zwei bestimtme Zahlen nicht nebeneinadner sind? Java Basics - Anfänger-Themen 3
K mit <<1 kann man mal 2 machen, mit >>2 geteilt durch zwei und was bewirkt <<<1 und >>>1? Java Basics - Anfänger-Themen 5
Dorfschmied Kartesisches Produkt von zwei Liste mit Hashmaps<String,String> erstellen Java Basics - Anfänger-Themen 4
F Abstand zwischen zwei Objekten berechnen wie? Java Basics - Anfänger-Themen 1
M Wie kann ich ein Array in zwei Hälften aufteilen? Java Basics - Anfänger-Themen 12
S Längster Pfad zwischen zwei Vertices in einem Graph Java Basics - Anfänger-Themen 3
S Aktuell beste Methode um zwei Bilder zu vergleichen..? Java Basics - Anfänger-Themen 1
A Zwei XML-Dateien Mergen Java Basics - Anfänger-Themen 14
U Erste Schritte nextGaussian zwischen zwei Werten Java Basics - Anfänger-Themen 19
S Multiplikation von zwei Labels Java Basics - Anfänger-Themen 7
U zwei 2D arrays auf gleich sein überprüfen Java Basics - Anfänger-Themen 14
Bademeister007 Elemente aus zwei verschiedenen Arrays miteinander vergleichen und gegeben falls entfernen Java Basics - Anfänger-Themen 14
Düsseldorf2002 Datentypen Zwei dimensionale LinkedList Java Basics - Anfänger-Themen 8
S Objekte von zwei klassen in zwei verschiedene Textdateien schreiben Java Basics - Anfänger-Themen 5
J Zwei Objekte vergleichen Java Basics - Anfänger-Themen 8
X Zwei Dimensionales Array prüfen Java Basics - Anfänger-Themen 1
G Methoden Informationen aus zwei Objekte bekommen? Java Basics - Anfänger-Themen 6
E Wie gebe ich alle Daten zwischen zwei Zeitpunkten aus? Java Basics - Anfänger-Themen 2
Q Besitzen zwei Strings identische Buchstaben, nur in anderer Reihenfolge? Java Basics - Anfänger-Themen 10
pkm Regexproblem - Wie kann ich zwei oder mehr beliebige Zeichen matchen? Java Basics - Anfänger-Themen 7
A Wieso bekomme ich hier zwei unterschiedliche Ausgaben? Java Basics - Anfänger-Themen 6
H Ein gegebenes Int Array zu Zwei Arrays zurück geben Java Basics - Anfänger-Themen 6
J zwei String Arrays miteinander vergleichen Java Basics - Anfänger-Themen 18
R Methode zwei Sortierkriterien der Klasse Comparator übergeben Java Basics - Anfänger-Themen 4
B Collections.sort mit zwei Bedingungen? Java Basics - Anfänger-Themen 4
X Textdatei: zwei-zeilenweise gleiche Zeilen rausschmeißen Java Basics - Anfänger-Themen 21
M Konkatenation von zwei Strings Java Basics - Anfänger-Themen 6
J Problem beim vergleich von zwei Integer Java Basics - Anfänger-Themen 3
D Input/Output Input von zwei Koordinaten validieren und anschließend Werte speichern Java Basics - Anfänger-Themen 7
L Zwei sortierte Subarrays mit gleicher Länge zusammenfügen Java Basics - Anfänger-Themen 2
F Zwei Dimensionles Array Java Basics - Anfänger-Themen 21
I Alle Elemente von zwei Listen vergleichen Java Basics - Anfänger-Themen 1
J Inhalte von zwei Arrays vertauschen?! Java Basics - Anfänger-Themen 6
O zwei Arrays nach Werten durchsuchen und zusammenfügen Java Basics - Anfänger-Themen 3
A Wie zwei zahlen in einer Variable speichern? Java Basics - Anfänger-Themen 7
N Zwei Daten (Datum) miteinander vergleichen, abspeichern, laden Java Basics - Anfänger-Themen 4
X Threads Zwei Threads, aber doppelte Ausgabe verhindern (synchronized) Java Basics - Anfänger-Themen 54
B Relativen Anteil von zwei Datümer auf Monatsebene umrechnen Java Basics - Anfänger-Themen 130
W Zwei Programme sollen auf eine Klasse zugreifen Java Basics - Anfänger-Themen 18
B Rückgabe von zwei Werten: String und double Java Basics - Anfänger-Themen 14
J Zwei Klassen die sich gegenseitig referenzieren - Bad practice? Java Basics - Anfänger-Themen 4
B Anzahl von Stunden / Tage von zwei Datumswerten ermitteln Java Basics - Anfänger-Themen 1
L Erste Schritte Elemente zwei Schlangen vergleichen Java Basics - Anfänger-Themen 14
N Zwei Strings mit "==" vergleichen warum TRUE Java Basics - Anfänger-Themen 2
D Input/Output InputDialog mit zwei Inputfeldern? Java Basics - Anfänger-Themen 4
D Funktion zwei Arraylisten zu verleichen ob gleich funktioniert nicht Java Basics - Anfänger-Themen 26
S Daten aus zwei Verschiedenen Tabellen in eine ArrayListe Java Basics - Anfänger-Themen 4
D Zwei Strings sind gleich bei if aber nicht true Java Basics - Anfänger-Themen 2
E Best Practice Jar-file mit zwei Klassen und externer Bibliothek über Konsole erzeugen Java Basics - Anfänger-Themen 13
J Logging erzeugt zwei dateien.... Java Basics - Anfänger-Themen 7
S zwei-dimensionales Array Java Basics - Anfänger-Themen 20
R Zwei Attribute gleichzeitig ausgeben Java Basics - Anfänger-Themen 12
javajoshi Problem mit zwei Threads und Arrays (Runnable) Java Basics - Anfänger-Themen 12
T Classpath Zwei gleiche Dateinamen in verschiedenen Projekten möglich? Java Basics - Anfänger-Themen 13

Ähnliche Java Themen

Neue Themen


Oben