Thread => Resource

[mariusmeier]

Hallo zusammen

Ich habe folgendes Szenario: Ein Thread bearbeitet eine Queue, welche Nachrichten für einen Server beinhaltet. In der Queue hole ich mir jeweils eine Nachricht und versende diese an den Server. Danach muss ich warten, bis eine Antwort zurück kommt. (Serielle Datenkommunikation) Falls keine Antwort zurück kommt, startet innerhalb von 10 Sekunden ein TimerTask(), welcher die Queue von den Verbindungen löst, welche nicht gesendet werden konnte.
Leider jedoch während diesen 10 Sekunden ist die CPU Usage 100%, da einfach der Thread in der while() Schlaufe wartet bis entweder eine Nachricht zurück kommt oder der TimerTask gestartet wird. Wie kann man nun die Usage so gestalten, dass da die CPU nicht 100% ausgelastet wird. Muss ich meine Queue anderst programmiere ?

while(!getMessageQueue().isEmpty()) {
				System.err.println("Queue handling!");
				/*---------------------Get message from queue----------------------------*/
				if(getNextMessage) {
					try {
						currentMessage = (Vector) getMessageQueue().poll();
					} catch(NoSuchElementException e) {
						System.err.println("Empty queue!");
					}
					
					if(currentMessage != null) {
						deviceAddress = (String)currentMessage.get(0);
						deviceType = (String)currentMessage.get(1);
						sendBuffer = (byte[])currentMessage.get(2);
						getNextMessage = false;
						sendMessage = true;
						
						if(releaseTimer == null) {
							releaseTimer = new Timer();
							releaseTimer.schedule(new ReleaseQueueTask(deviceAddress, deviceType), releaseTime);
						}	
					} else {
						//Queue is empty!
						getNextMessage = false;
						sendMessage = false;
					}
				}
				/*-----------------End get message from queue----------------------------*/
				
				/*-------------------------Send message----------------------------------*/
				else if(sendMessage) {
					sendMessage = false;
					boolean isWritingToDevice = false;
					IDriver device = searchIDriver(deviceAddress);
					if(device != null) {
						try {
							System.err.println("Write with registered driver: " + device.getDeviceAdress());
							device.write(sendBuffer, sendBuffer.length);
							isWritingToDevice = true;
						} catch (IOException e) {
							System.err.println("Failure by sending Message! (Existing driver)");
						}
					} else {
						//If driver does not exists, we have to create a temporarily driver to communicate with frontend.
						//This could happen, if the frontend has no active measure channel.
						registerDevice(deviceAddress, deviceType);
						device = searchIDriver(deviceAddress);
						if(device != null) {
							try {
								device.write(sendBuffer, sendBuffer.length);
							} catch (IOException e) {
								System.err.println("Failure by sending Message! (New driver)");
							}
						}
					}	
				} else {
					try {
						Thread.sleep(2000);
					} catch (InterruptedException e) {
						System.out.println("Thread sleep error: " + e.getMessage());
					}
				}
				/*---------------------End send message----------------------------------*/
			}

Irgendwie sollte doch möglich sein, den Thread in einen idle state zu senden. Die methoden von ServerSocket haben ja auch eine accept Methode... wenn ich dort in einer while-Schlaufe diese accept Methode betreibe, wird auch nicht 100% CPU ausgelastet. Was kann man tun ?

MFG

 

[Michael...]

Hier mal wie ich das verstanden habe:
Wenn eine Nachricht erfolgreich versendet wurde oder nach 10 sec keine Antwort zurückgekommen ist, wird sie aus der Queue gelöscht. Es wird eine Nachricht nach der anderen gesendet - also kann es vorkommen, dass der Client 10 sec warten muss, bis die nächste Nachricht versendet werden kann.

Dann könnte man nach dem Versenden einfach einen Thread oder Timer starten, der erst einmal 10 sec schlafen gelegt wird. Kommt innerhalb der 10 sec eine Antwort wird die Nachricht aus der Queue gelöscht. Nach 10 sec erwacht der Thread/Timer und prüft ob die Nachricht noch in der Queue ist, wenn ja, dann löscht er die Nachricht und meldet dem Sendethread, dass die nächste Nachricht gesendet werden kann.

 

[Marco13]

Der Code ist erstmal nicht so leicht nachvollziehbar. Aber wenn da irgendein Thread auf sowas wie einem Socket ein "read" ausführt, dann (kann man dem AFAIK auch ein Timeout übergeben? und dann) blockiert er doch automatisch!?

 

[mariusmeier]

Hallo

Ja Michael, so wäre es gedacht. Es kann vorkommen das die Queue für 10 Sekunden gesperrt ist für andere Geräte. Das ist bis jetzt soweit in Ordnung.
Dein Vorschlag mit dem Timer muss ich mir genauers Überlegen. Momentan ist es ja so, dass jeweils mit put das Element aus der Queue gerade gelöscht wird. Ich hole mir also immer ein Element aus der Queue und lösche es aber gerade. Da die Steuerbefehle auf das Gerät via TCP realisiert sind, kann ich davon ausgehen, dass wenn innerhalb dieser 10 Sekunden keine Nachricht zurück kommt, irgendwas schief gelaufen ist.
Marco: Das read geschieht ja in einem anderen Teil (In einem Treiber) der unabhängig von dieser Queue arbeitet. Man könnte vielleicht auf dieser Ebene der Queue signalisieren, dass sie nicht länger warten muss, da Kommunikationsprobleme aufgetreten sind.
Trotzdem will ich nochmals nachfragen, ob man die while-Schlaufe in einem Thread so realisieren kann, dass diese nicht die 100% CPU Usage verursacht?

MFG

 

[mariusmeier]

Hallo zusammen

Ich habe mein Problem mit der wait-notify Variante gelöst. Falls eine Nachricht versendet wird, wird der Thread mit wait() angehalten bis eine Nachricht vom Server zurück kommt oder der TimerTask ein Verbindungsproblem meldet. Bei beiden Möglichkeiten rufe ich dann wieder notify() auf.

MFG