Probleme bei Threads mit Rückgabe.

[0001001]

Hallo Ihr,

ich habe folgendes Interface und folgende Klasse:

public static interface myrunnable extends Runnable{
		public Object getValue();
}

public class Test {
    public void methode1(){
        class Thread1 implements myrunnable{
			private String abc;
			public void run(){
				// do something with abc
			}
			public String getValue(){
				return abc;
			}
		};
		
		class Thread2 implements myrunnable{
			private String def;
			public void run(){
				// do something with def
			}
			public String getValue(){
				return def;
			}
		};
		
		[Thread1 laufen lassen]...
		[Thread2 laufen lassen]...
		
		class Thread3 implements myrunnable{
			private String ghi;
			public void run(){
				String t3_abc = Thread1.getValue(); // mit Hilfe von getValue() auf das Ergebnis von Thread1 zugreifen
				String t3_def = Thread2.getValue(); // mit Hilfe von getValue() auf das Ergebnis von Thread2 zugreifen
			}
			public String getValue(){
				return ghi;
			}
		};
		[Thread3 laufen lassen]...
    }
}

Ich hab noch kaum Erfahrung mit Threads. Was ich machen möchte ist folgendes: Ich muss auf Ergebnisse zugreifen, die innerhalb eines Threads "berechnet" werden. Dazu hab ich mir ein neues Interface definiert, das Runnable um die Methode getValue erweitert. Soweit so gut.
Probleme hab ich zum einen die Threads laufen zu lassen, vielleicht kann mir hier jmd einen Tip geben?
Zum anderen weiss ich nicht wie ich innerhalb von Thread3 auf die getValue() Methoden von Thread1 und Thread2 zugreifen kann.

Über Hilfe wäre ich wirklich sehr dankbar!!!

 

[madboy]

Hi Du,

Starten lässt sich ein Thread so:

IReturnRunnable my1 = new Thread2(); //Thread2 muss  IReturnRunnable implementieren und nicht myrunnable
Thread t1 = new Thread(my1);
t1.start();

Zum Holen von Werten aus Thread3 müssen die Instanzen von Thread1 und Thread2 der Instanz von Thread3 bekannt sein.

Zum Beispiel über den Konstruktor:

      class Thread3 implements myrunnable{ 
         private String ghi; 
        private Thread1 t1;
        private Thread2 t2;

         public Thread3 (Thread2 t2, Thread1 t1) {
             this.t1 = t1;
             this.t2 = t2;
         }
         public void run(){ 
            String t3_abc = t1.getValue(); // mit Hilfe von getValue() auf das Ergebnis von Thread1 zugreifen 
            String t3_def = t2.getValue(); // mit Hilfe von getValue() auf das Ergebnis von Thread2 zugreifen 
         } 
         public String getValue(){ 
            return ghi; 
         } 
      };

Allerdings können Probleme mit der Synchronisation auftreten (sehr schwierig, die zu reproduzieren/finden)...
So kann es z.B. sein dass Thread3 als erstes startet und auch fertig wird => Thread2 und Thread1 haben noch keine Ergebnisse produziert => Problem :wink:
Eine Lösung fällt mir auf Anhieb nicht ein (ausser evtl. auf die Beendigung von Thread1 und Thread2 zu warten).

Gruß,
madboy

 

[0001001]

Hey prima danke!
Ich probiers mal mit deinen Beispielen!
Falls ich noch Fragen hab, werde ich sie hier posten!

Das mit myrunnable war mein Fehler hatte vergessen das für das Beispiel auszubessern.

 

[0001001]

Hallo nochmal,

leider hab ich ein kleines Problem beim Zugriff auf die Instanz von Thread1 und Thread2 über den Konstruktor:

class Thread3 implements myrunnable{
	private String ghi;
    private Thread1 t1;
    private Thread2 t2;
    public Thread3 (Thread2 t2, Thread1 t1) {
    	this.t1 = t1;
        this.t2 = t2;
    }
    public void run(){
    	String t3_abc = t1.getValue(); // funktioniert nicht weil Thread keine Methode getValue() besitzt
        String t3_def = t2.getValue(); // funktioniert nicht weil Thread keine Methode getValue() besitzt
    }
    public String getValue(){
    	return ghi;
    }
};

Problem ist, dass die Klasse Thread keine Methode getValue() besitzt. Aber ich dadurch erzeuge ja ein Thread Objekt:

myrunnable my1 = new Thread1(); 
Thread t1 = new Thread(my1);
t1.start();

Wenn ich t1 nun Thread3 übergebe, dann ist das ja ein Threadobjekt, das keine getValue Methode hat. Wie komme ich aus diesem Dilemma raus...?

 

[André Uhres]

package thread;
/*
 * Test.java
 */
public class Test {
    private Thread1 run1;
    private Thread2 run2;
    private Thread3 run3;
    public Test(){
        run1 = new Thread1();
        run2 = new Thread2();
        run3 = new Thread3(run1, run2);
        Thread th1 = new Thread(run1);
        Thread th2 = new Thread(run2);
        Thread th3 = new Thread(run3);
        th1.start();
        th2.start();
        try {
            //warten bis die beiden ersten Threads fertig sind:
            th1.join();
            th2.join();
        } catch (InterruptedException ex) {
            ex.printStackTrace();
        }
        //der dritte Thread kann dann die Ergebnisse verwenden:
        th3.start();
    }
    class Thread1 implements MyRunnable{
        private String abc = "abc";
        public void run(){
            try {Thread.sleep(300);} catch (InterruptedException ex) {}
            abc = "bca";
        }
        public String getValue(){
            return abc;
        }
    };
    class Thread2 implements MyRunnable{
        private String def = "def";
        public void run(){
            try {Thread.sleep(300);} catch (InterruptedException ex) {}
            def = "fed";
        }
        public String getValue(){
            return def;
        }
    };
    class Thread3 implements MyRunnable{
        private String ghi = "ghi";
        private Test.Thread1 run1;
        private Test.Thread2 run2;
        public Thread3(Thread1 run1, Thread2 run2){
            this.run1 = run1;
            this.run2 = run2;
        }
        public void run(){
            String t3_abc = run1.getValue();
            String t3_def = run2.getValue();
            System.out.println(t3_abc+" "+t3_def);
        }
        public String getValue(){
            return ghi;
        }
    };
    public static void main(final String[] args){new Test();}
}
interface MyRunnable extends Runnable{
    public Object getValue();
}

 

[madboy]

Da ist wohl meine Benennung der Instanzen nicht ganz glücklich gewesen 🙁

Es dürfen keine Objekte vom Typ Thread übergeben werden sondern Objekte vom Typ Thread1 und Thread2.

also so etwa:

Thread1 myThread1 = new Thread1(); 
Thread t1 = new Thread(myThread1); 
t1.start();

Thread2 myThread2 = new Thread2(); 
Thread t2 = new Thread(myThread2); 
t2.start();

Thread2 myThread3 = new Thread3(myThread1, myThread2);
Thread t3 = new Thread(myThread3); 
t3.start();

Gruß,
madboy

P.S.
Zur Lektüre zu Threads allgemein und speziell z.B. :
http://www.galileocomputing.de/openbook/javainsel6/javainsel_09_001.htm

 

[0001001]

Hallo Ihr beiden,

vielen Dank für eure Hilfe. Jetzt klappt es wie gewünscht!