Problem mit Threads

[Marcel82]

Hi
Ich habe ein Porgramm geschrieben welches ein an den PC angeschlossenes Gerät identifzieren soll. Dazu schickt es nacheinander auf allen COMPorts eine Nachricht und wartet auf eine Antwort. Wenn eine Echo kommt, dann ist das gerät gefunden.

Die Ports gehe ich in einer Schleife nacheinander durch, vor jedem versenden starte ich einen Listen Thread, der nach der Antwort lauscht und im Erfolgsfall im Haupthread eine Variable auf true setzten soll. Der Hauptthread schläft nach dem versenden eine kurze Zeit.

Und genau da liegt das Problem, der Listenthread setzt die Variable nicht auf True.

import gnu.io.CommPort;
import gnu.io.CommPortIdentifier;
import gnu.io.SerialPort;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;

import org.eclipse.swt.custom.StyledText;

public class SerialComm {
	private Enumeration portList;
	private CommPortIdentifier portIdentifier;
	public boolean M500Found = false;
	public Thread listenThread;

	public SerialComm() {
		super();
	}

	void connect(StyledText log) throws Exception {
		portList = CommPortIdentifier.getPortIdentifiers();
		log.append("Scanning Ports:\n");
		while (!M500Found) {
			portIdentifier = (CommPortIdentifier) portList.nextElement();
			if (portIdentifier.getPortType() == CommPortIdentifier.PORT_SERIAL) {
				log.append(portIdentifier.getName() + "\n");
				System.out.println(portIdentifier.getName() + "\n");

				if (portIdentifier.isCurrentlyOwned()) {
					System.out.println("Error: Port is currently in use");
					log.append("Error: Port is currently in use\n");
				} else {
					CommPort commPort = portIdentifier.open(this.getClass()
							.getName(), 2000);

					if (commPort instanceof SerialPort) {
						SerialPort serialPort = (SerialPort) commPort;
						serialPort.setSerialPortParams(115200,
								SerialPort.DATABITS_8, SerialPort.STOPBITS_1,
								SerialPort.PARITY_NONE);

						InputStream in = serialPort.getInputStream();
						OutputStream out = serialPort.getOutputStream();

						listenThread = new Thread(new SerialReader(in,
								M500Found));
						listenThread.start();
						out.write("a".getBytes());
						Thread.sleep(3000);
						listenThread.destroy();
						serialPort.close();

					}
				}
			}
		}
	}

	/** */
	public static class SerialReader implements Runnable {
		InputStream in;
		boolean found;

		public SerialReader(InputStream in, boolean found) {
			this.in = in;
			this.found = found;
		}

		public void run() {
			byte[] buffer = new byte[1024];
			int len = -1;
			try {
				System.out
						.println("TreadID: " + Thread.currentThread().getId());

				while ((len = this.in.read(buffer)) > -1) {

					System.out.print(new String(buffer, 0, len));
					if (buffer.equals("a"))
						found = true;

				}
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

}

 

[Marcel82]

das listenThread.destroy();
habe ich mal entfernt, das is wohl veraltet, macht ja auch nix wenn die Threads erstmal weiterlaufen vorerst

Auf jedenfall bleibt das ganze nach erzeugung des ersten Threads hängen, es passiert garnix mehr.

 

[lhein]

1. Du killst deinen ListenerThread nach 3 Sekunden...was ist wenn die Antwort länger als 3 Sekunden dauert?
2. serialPort.close(); schliesst den Port....wie soll er dann auf eine Antwort lauschen?

 

[SlaterB]

buffer ist ein byte-Array, ein byte-Array ist niemals equal zu einem String

 

[lhein]

jo, das ist ebenfalls ein Killer

 

[Gast]

3 Sekunden sollten doch reichen um eine Antwort zu bekommen oder? kann ja auch 10 machen erstmal

 

[Gast]

if (buffer.equals("a".getBytes()))
sollte dann richtig sein oder?

Scheinbar blockiert das in.read() bis was kommt, aber komsicherweise häng der Hauptthread auch, woran kann das liegen?

 

[SlaterB]

auch zwei byte-Array sind niemals equal wenn sie nicht ein und derselbe sind
kann man doch alles testen..,

prüfe entweder auf Länge 1 und char 'a' an Position 0 oder erstelle einen String aus dem Array, wie du es für die Ausgabe eine Zeile davor schon gemacht hast

 

[Guest]

ok, das mit dem überprüfen habe ich geändert, wieso hängt aber der Hauptthread?

istenThread = new Thread(new SerialReader(in,
								M500Found));
						listenThread.start();
						out.write("a".getBytes());
						Thread.sleep(3000);
						System.out.println("ausgeschlafen");
//						listenThread.destroy();
						listenThread.interrupt();
						System.out.println("interrupted");
						System.out.println("found "+M500Found);

						
						serialPort.close();
						System.out.println("close");

Das ganze bleibt bei serialPort.close(); hängen, kann mir jemand erklären warum?

 

[Gast]

guck mal in die doc, möglicherweise blockiert close, wenn der port nicht anständig geöffnet wurde. du haust dem thread nach 3 sekunden brutal einen auf die nuss, da können die verbindungen durchaus in irgendeinem undefinierten zustand hängen.

würd das ganze erstmal völlig ohne threads lösen. und wenns dann funzt, kann man multithreading immer noch nachziehen.

 

[Gast]

Wie soll das denn aber ohne Treads funkionieren? Ich muss doch gleichzeitig schreiben und hören.

 

[FArt]

Das Flag aus der Hauptklasse, welches von einem Thread gesetzt und vom anderen gelesen wird muss mit dem Schlüsselwort "volatile" deklariert werden, da sonst eine Änderung nicht unbedingt sichtbar ist (siehe JSR-133).