Thread JavaFish

[Mappenz]

Hallo,

ich habe meine Probleme mit multithreading auf diesen jUnit code reduziert:

	private class jfmThread extends Thread {
		int iHandle;
		
		public jfmThread(int serial) {
			iHandle = new JavaFish().jrOpenInterfaceUSB(60, serial);
		}
		
		public synchronized void run() {
			System.out.println(iHandle);
			new JavaFish().jrSetMotorEx(iHandle, 1, 1, 6);
			try {
				wait(10000);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			new JavaFish().jrCloseInterface(iHandle);
			System.out.println(iHandle);
		}
	}
	
	@Test
	public void motorThreadTest() {
		
		new jfmThread(0x11).start();
	}

Die Ausgabe ist:

0

Wenn ich nur run() aufrufe läuft das Programm wie erwartet. Das Problem hängt also direkt mit der Nebenläufigkeit zusammen. Was kann dabei schief gehen?

Viele Grüße
Michael

 

[Paddelpirat]

Also ein Minimalbeispiel bezüglich Multithreading ist das bestimmt nicht. Außerdem hättest du mal schreiben können, woher dieses JavaFish kommt.
Ich denke deine Probleme kommen eher dadurch zustande, dass du immer

new JavaFish().irgendwas

aufrufst. Das hat zur Folge, dass du die

irgendwas

-Aufrufe auf unterschiedliche Objekte ausführst. Versuchs mal so:

private class jfmThread extends Thread {
        int iHandle;

        JavaFish ft;
        
        public jfmThread(int serial) {
            ft = new JavaFish();
            iHandle = ft.jrOpenInterfaceUSB(60, serial);
        }
        
        public synchronized void run() {
            System.out.println(iHandle);
            ft.jrSetMotorEx(iHandle, 1, 1, 6);
            try {
                wait(10000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            ft.jrCloseInterface(iHandle);
            System.out.println(iHandle);
        }
    }
    
    @Test
    public void motorThreadTest() {
        
        new jfmThread(0x11).start();
    }

 

[irgendjemand]

ähm ... Thread und synchronized ? was soll das denn werden ?

btw : mein vorredner hat die antwort schon gegeben : innerhalb der schleife erzeugst du immer wieder ein neues objekt ... ist klar das dann nicht das rauskommt was du haben willst

 

[Mappenz]

Hallo,

danke für die Antworten. Der neue Code Funktioniert auch nicht. Die Ausgabe ist die gleiche. Du hast recht, zu JavaFish gibt es etwas zu sagen. JavaFish ist ein JNI wrapper für C++ Code. Beides habe ich nicht als Quellcode zur Verfügung. JavaFish dient als Schnittstelle zur Steuerung von Robotern. Wenn Null ausgegeben wird ist das gut, das bedeutet dass das Interface mit der Nummer Null offen ist. In einem sequenziellen Programm kann ich beliebige JavaFish Instanzen synonym benutzen. Das habe ich natürlich schon ausprobiert:

	public void multipleJavaFishInstances() {
		jf = new JavaFish();
		JavaFish jf2 = new JavaFish();
		int iHandle = jf.jrOpenInterfaceUSB(arg0, 0x1);
		System.out.println(jf2.jrCloseInterface(iHandle));
		
	}

Funktioniert.

In einem sequenziellen Programm bekommt man eine Ausgabe dass eine Exception außerhalb der JVM passiert ist falls beim Aufruf irgend welcher JavaFish Funktionen was schief ging, das Programm ist dann beendet.

Synchronized brauche ich für wait(), was ist daran auszusetzen?

Viele Grüße
Michael

 

[Guardi]

Also soll das Starten des Threads synchronisiert laufen?
Das bedeutet z.B. ein Thread blockiert alle anderen Threads die wiederum diesen Thread starten wollen.
Normalerweise synchronisiert man die Aufrufe auf Objekte.

 

[SlaterB]

der Start ist nicht synchronisiert, sondern die run-Methode, sicherlich auch beim ersten Antritt zum Start des Threads,

durch das lange Warten ist die Synchronisation oft genug freigegeben,
die restlichen Aktionen der run-Methode sollen aber sicher ausgeführt werden,
das kann man genau so machen, in einer Untermethode wäre es vom Ablauf her nicht anders

> Das bedeutet z.B. ein Thread blockiert alle anderen Threads die wiederum diesen Thread starten wollen

ein Thread blockiert alle anderen Threads die (auch synchronisierte) Methoden während der kritischen Phase aufrufen wollen,
das entspricht der Definition und der Aufgabe der Synchronisation,
(edit: andere Methoden gibts aber gar nicht im geposteten Code, insofern derzeit wirklich unnütz)

der Start könnte durchaus auch geschützt ablaufen bzw. bietet sich gerade an,
wenn du etwa heraufbeschwörst, dass 'mehrere Threads' einen Thread starten wollen
und es schlecht wäre, wenn mehr als einer gestartet wird

 

[Mappenz]

Hängt euch bitte nicht am synchronized auf. Das wait() habe ich eingebaut, damit die Maschine ein weilchen läuft. Mit anderem Code liefen die Modelle ganz kurz und dann war schluss. Ohne synchronized gibts ne exception.

Ich möchte den Code doch noch etwas stärker auf das wesentliche reduzieren.

 private class jfmThread extends Thread {
        jf = new JavaFish();
        int iHandle;
        
        public jfmThread(int serial) {
            iHandle = new JavaFish().jrOpenInterfaceUSB(60, serial);
        }
        
        public void run() {
            System.out.println(iHandle);
            jf.jrSetMotorEx(iHandle, 1, 1, 6);
            System.out.println("End Run");
        }
    }
    
    @Test
    public void motorThreadTest() {
        
        new jfmThread(0x11).start();
    }

Die erwartete Ausgabe ist

0
End Run

Tatsächlich wird aber nur 0 ausgegeben.

 

[SlaterB]

wenn du nur warten willst, ginge sleep() statt wait(), dann auch ohne synchronized,
und niemand schaut nach notify(), welches üblicherweise zum wait() dazugehört

das Problem wird wohl sein, dass 'new JavaFish().jrOpenInterfaceUSB(60, serial);' noch vom Original-Thread ausgeführt wird,
der Rest dann vom neuen Thread,
du könntest 'new JavaFish().jrOpenInterfaceUSB(60, serial);' an den Beginn der run-Methode setzen

das wäre zumindest ein struktureller Unterschied, der deinen erfolgreichen Testfall bestätigen würde,
allgemein kann man über unbekannte Klassen nun wenig sinnvolles philosophieren,
vielleicht werden generell alle Threads außer main abgelehnt,..

 

[Mappenz]

	 private class jfThread extends Thread {
		 	JavaFish jf= new JavaFish();
	        int iHandle;
	        int serial;
	        
	        public jfThread(int serial) {
	        	this.serial = serial;
	        }
	        
	        public void run() {
	        	System.out.println("Run");
	        	iHandle = new JavaFish().jrOpenInterfaceUSB(60, serial);
	            System.out.println(iHandle);
	        }
	    }
	    
	    @Test
	    public void motorThreadTest() {
	        
	        new jfThread(0x11).start();
	    }

Ausgabe ist

Run

. Es wäre schon schön zu verstehen worin das Problem liegt. Kann ich euch irgend was erzählen das hilft?

 

[SlaterB]

unbekannte Klassen sind nicht unbedingt viel besser als direkt der C++-Code, der damit verborgen werden soll,
nur weil Java draufsteht muss das niemand verstehen können

bei Suche lande ich bei
Java Beispiel : Ampel mit Swing
hast du dieses Beispiel ausprobiert?
gibt es eine vorgegebene Klasse FishThread?

was mir bei dir schon immer auffällt: du schreibst ständig 'new JavaFish()', jedenfalls öfter als 1x pro Programm,
vielleicht hilft es generell wenn du nur bei EINEM Objekt bleibst, wo auch immer es erstellt wurde,
siehe Link, allerdings ist dort nix von jrOpenInterfaceUSB() zu sehen

 

[Mappenz]

Interessant, diese Seite war zuletzt nicht erreichbar. Das von dir gefundene Beispiel kannte ich auch nicht. Ich sehe aber, dass sich die Signaturen der dort verwendeten JavaFish Funktionen von meinem unterscheiden. Ich hatte bis jetzt auch nur JavaFish, kein FishThread.

Du hast recht, es war nach der vorherigen Kritik ein versehen new JavaFish() aufzurufen. Es macht aber keinen unterschied, habs nochmal ausprobiert.

Mal sehen ob ich JavaFish von der Seite benutzen kann, sieht ja schon komfortabler aus. Vielleicht funktionierts auch besser.