Queue zyklisch auslesen

[javarian]

Hi

ich hab eine queue

public static Queue<byte[]> queue = new LinkedList<byte[]>();

diese liegt in einer eigenen Klasse und Thread und soll falls ich was hineinschrieben eine Funktion aufrufen die diesen neuen Wert an die Funktion übergibt.

Habe im Moment mit einer schleife die auf is.Empty prüft und den lass den Thread für eine Sekunde schlafen.
Ich würde es aber gerne so lösen das es ohne die warte Zeit auskommt. Das direkt wenn ein neues Zeichen in der queue ist die Funktion aufruft.

Weis nur nicht ganz wie, muss ich da mutex oder so implementieren?

Hat jemand eine idee und am besten ein einfaches Beispiel wie ich das löse?

Grüße

 

[Saheeda]

Nur ne Idee: Für mich schreit das geradezu nach nem eigenen Event. Vielleicht kannst du damit was anfangen:

https://castever.wordpress.com/2008/07/31/how-to-create-your-own-events-in-java/

 

[Dompteur]

Java bietet Mechnismen zur Synchronisierung von Threads. Stichworte : notify() und wait().
Details findest du hier : Rheinwerk Computing :: Java ist auch eine Insel – 14.6 Synchronisation über Warten und Benachrichtigen

 

[javarian]

@Scheeda Habe es mir mal angeschaut vielen Dank dafür aber suche erst mal einen einfacheren Weg.

@Dompteur Habe es jetzt mal umgesetzt nur das Problem ist das ich eine illegalmonitorstateexception bekomme.

Zur Erklärung:
Habe zwei Klassen eine Queue Klasse, welche die Queue beinhaltet, die instantierung der condition und dem lock. In welcher das lesen aus der queue gelockt wird.

Und eine Klasse die über das statische Lock in der ersten Klasse, den Threat der ersten Klasse frei geben soll und damit aus der Queue lesen soll.

Ich denke das Problem ist das es in zwei verschiedenen Klassen aufgeteilt ist oder? Ne Idee?

Grüße

 

[Dompteur]

Häufig liegt die Ursache für illegalmonitorstateexception darin, dass du dich nicht in einem synchronizierten Codestück befindest. Eigentlich sollte bei der Ausgabe des Stacktraces noch ein erklärender Text dabei stehen.
Ansonsten poste einmal dein Beispiel.