public class BufferedQueue<E>
extends java.lang.Object
put(E)
können beliebige Objekte (Nachrichten) in die Queue eingetragen
(gesendet) werden und i.a. von einem anderen Thread mit den Methode take()
aus der Queue entnommen (empfangen) werden. Die Anzahl der
Nachrichten in der Queue ist beschränkt. Die Nachrichten werden in der Reihenfolge empfangen in der sie versendet wurden (first in first out,
FIFO). Gesendete Nachrichten stehen erst dann empfangsseitig zur Verfügung, wenn die halbe Kapizität der Queue erreicht ist oder die Methode flush()
aufgerufen wurde.Constructor and Description |
---|
BufferedQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
void |
flush() |
void |
put(E message)
Sendet eine Nachricht in die Queue.
|
E |
take()
Empfängt und entfernt eine Nachricht aus der Queue.
|
public void flush() throws java.lang.InterruptedException
java.lang.InterruptedException
public void put(E message) throws java.lang.InterruptedException
message
- Zu versendende Nachricht.java.lang.InterruptedException
public E take() throws java.lang.InterruptedException
java.lang.InterruptedException
- Wenn der Thread unterbrochen wurde während auf Nachrichten gewartet wurde.