private class ClientHighLevelCommunication.SendControlNotifier
extends java.lang.Object
implements java.lang.Runnable
Asynchrone Verarbeitung von empfangenen Sendsteuerungstelegrammen. Speichert mit put übergebene Sendesteuerungstelegramme in einer internen Queue, aus der die Telegramme asynchron von einem eigenen Thread ausgelesen und zur Weiterverarbeitung an den SubscriptionsManager weitergegeben werden.
Modifier and Type | Field and Description |
---|---|
private UnboundedQueue<RequestSenderDataTelegram> |
_telegrams |
Constructor and Description |
---|
SendControlNotifier()
Der Konstruktor erzeugt die interne Queue.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Signalisiert dem Thread zur Verarbeitung der Telegramme, dass keine weiteren Telegramme verarbeitet werden müssen und der Thread sich beenden kann.
|
void |
put(RequestSenderDataTelegram telegram)
Speichert das übergebene Telegramm in der Queue zur asynchronen Verarbeitung.
|
void |
run()
Methode zur asynchronen Verarbeitung von gespeicherten Telegrammen durch einen eigenen Thread.
|
private void |
start()
Erzeugt und startet einen separaten Thread zur Verarbeitung der Telegramme.
|
private UnboundedQueue<RequestSenderDataTelegram> _telegrams
public SendControlNotifier()
Der Konstruktor erzeugt die interne Queue. Der Thread zur Verarbeitung der Telegramme wird erst später bei Aufruf der start()-Methode angelegt und gestartet.
private void start()
Erzeugt und startet einen separaten Thread zur Verarbeitung der Telegramme.
public void put(RequestSenderDataTelegram telegram)
Speichert das übergebene Telegramm in der Queue zur asynchronen Verarbeitung.
telegram
- Zu verarbeitendes Sendesteuerungstelegramm.public void close()
Signalisiert dem Thread zur Verarbeitung der Telegramme, dass keine weiteren Telegramme verarbeitet werden müssen und der Thread sich beenden kann.
public void run()
Methode zur asynchronen Verarbeitung von gespeicherten Telegrammen durch einen eigenen Thread.
run
in interface java.lang.Runnable