private class ClientHighLevelCommunication.SendControlNotifier extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
private UnboundedQueue<RequestSenderDataTelegram> |
_telegrams |
Constructor and Description |
---|
ClientHighLevelCommunication.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 ClientHighLevelCommunication.SendControlNotifier()
private void start()
public void put(RequestSenderDataTelegram telegram)
telegram
- Zu verarbeitendes Sendesteuerungstelegramm.public void close()