Event Queues in Java?

[Matrim Cauthon]

Hallo,

in meinem JavaProgramm kommen über verschiedene serielle Ports Daten ein, auf welchen ich Operationen laufen lassen muss.

Da die Datenflut sehr unregelmäßg auftritt, kann es vorkommen, dass z.B. zu gleichen Zeit Daten gelesen werden.
Wie kann ich nun in Java eine EventQueue der Daten aufbauen?
Also, dass die Daten, die egal auf welchen Port ankommen sofort als solche in einer Datenstruktur zwischengespeichert werden (vector ?) und weiterhin, dass es einen listener gibt, der jedesmal, wenn neue Daten zur Verfügung stehen, diese entnimmt und verarbeitet.

Dieses Verarbeiten dauert seine Zeit, so dass es möglich sein sollte, dass die Event trotzdem weiterhin in die Queue eingetragen werden.

Noch irgendwelche Tipps?

Danke im Voraus,

Mat.

 

[dotlens]

Listeners arbeiten mit Queue's.

Ich hab es selbst noch nie benötigt, denke aber es sollte funktionieren wenn du einen eigenen Listener machst und ihn
'EventListener' implementieren lässt.

 

[Guest]

Danke für die Antwort.

Funktioniert trotzdem nicht, hängt vielleicht damit zusammen, dass meine GUI via:

public static void main(String[] args) 
    {
        //Schedule a job for the event-dispatching thread:
        //creating and showing this application's GUI.
        javax.swing.SwingUtilities.invokeLater(new Runnable() 
        {
            public void run() 
            {
                createAndShowGUI();
            }
        });
    }

aufgerufen wird. Nun werden auch die seriellen Port Sachen innerhalb davon von GUI aufgerufen. Solange das Bearbeiten der Daten nicht lang dauert, klappt es auch. Aber sobald ich auf langsameren Rechner bin, werden Daten nicht mehr eingelesen vom seriellen Port, erst, wenn die Abarbeitung beendet ist (Gut bemerkbar mit Thread.sleep()).

Das was nun notwendig ist, dass das EventMonitoring der seriellen Schnittstellen einfach höher priorisiert werden müssten?

Mat.

 

[dotlens]

wieso machst du denn einen Thrad für deine GUI?

Die Priorität kannst du ändern, ich empfehle aber, die weniger wichtigen nidriger zu stufen anstatt die wichtigen zu erhöhen.

 

[Matrim Cauthon]

Den GUI in einem eigenen Thread laufen zu lassen, habe ich in einem SUN Swing Tutorial gelesen.

 

[AlArenal]

Swing selbst läuft eigentlich schon in einem eigenen Thread... Wenn, dann macht man eigene Threads für seine Berechnungen..

 

[Matrim Cauthon]

Würde mich freuen, wenn jemand noch eine Idee hat oder mir vielleicht mal ein neues Prinzip erläutert, sicher sehe ich irgendwas noch völlig falsch.

 

[Bleiglanz]

A) Swing Anwendungen sind SingleThreaded (....)

B) javax.swing.Timer

C) http://java.sun.com/docs/books/tutorial/uiswing/misc/threads.html

D) im java5 gibts einen ganzen Schwung threadsicherer Queues

z.B.: java.util.concurrent.ConcurrentLinkedQueue<E>

 

[Guest]

Also spalte ich dann einfach jeweils einen neuen Thread ab, für jedes Event?

 

[Bleiglanz]

no, mach für jeden seriellen Port einen Thread, der ständig lauscht und der die Eingehenden Daten in eine threadsichere Queue reinschreibt

vom grossen "Swing-Thread" aus dann ggf. abholen

 

[Matrim Cauthon]

Genau,

auf diese Idee bin ich auch gekommen, alles andere ware Quatsch.

Bleibt noch eine Frage, sollte der wirklich der Haupthread dann die Daten abholen (wie schaut eine solche Benachrichtung dann aus?) oder sollte es einen extra consumer thread geben, der dann von sich aus die Swing Applikation updated? Also der die Berechnungen anstellt und dann die Updates weiter gibt, so dass die SwingApplikation nicht blockiert?