von Reflection zum Thread?

[Thomas_java]

Hallo,

wie ich von einem Klassennamen als String zur Klasse (mit parametrierten Konstruktor) komme
habe ich soweit verstanden.
Jetzt soll die so erstellte Klasse noch als Thread laufen können.

Wie kann ich das erreichen?

...
try
{
	Constructor cons = clazz.getConstructor(params); //params zuvor deklariert
	Object[] args = new Object[]{str1, pipe.getRxPipe(), str2};
	Object obj = cons.newInstance(args);
        //
        // hier soll der Thread gebildet werden
        // Nach Umstellung auf das Reflection-API
        // gibts Fehler 
	Thread th = new Thread(new obj);
	th.start();
}
....

Vielen Dank

Thomas

 

[SlaterB]

wenn die Klasse ein Thread/ Runnable ist, dann kannst du casten,
ansonsten kann man nicht pauschal 'einen Thread zu einem beliebigen Objekt' starten

lasse doch mal Reflection weg und fange mit einem 'normalen' Objekt an:
String test = "xy";

was bedeutet es nun zum String test einen Thread zu erstellen?

 

[Niki]

Du musst schon wissen was do von deinem Objekt im Thread aufrufen willst. Ist es selbst ein Runnable, so kannst du es einfach dem Thread übergeben. Weißt du nur, dass dieses Objekt eine Methode xyz hat, dann kannst du die Methode via Reflection aufrufen. Ansonsten würde ich dir raten zumindest ein eigenes Interface vorzugeben. Dann würd das so aussehen:

Constructor cons = clazz.getConstructor(params); //params zuvor deklariert
Object[] args = new Object[]{str1, pipe.getRxPipe(), str2};
final Object obj = cons.newInstance(args);

if(obj instanceof MyInterface){
  new Thread(new Runnable(){
    public void run(){
      ((MyInterface)obj).doMyMethod();
    }
  ).start();
}

 

[Thomas_java]

ersteinmal vielen Dank für Eure Hinweise

Den Thread direkt aufzurufen funktioniert problemlos (siehe Code-Schnipsel).
So habe ich es auch bisher gemacht.

....
   Thread th = new Thread(new MyNewThread(str1, pipe.getRxPipe(), str2));
   th.start();
....

Die Idee, einen String zu übergeben, habe ich anschließend erfolglos versucht

public void MyFKT(String ThreadName, String str1, String str2)
{
....
   Thread th = new Thread(new ThreadName(str1, pipe.getRxPipe(), str2));
   th.start();
....
}

Im Nachhinein betrachtet ist es auch etwas naiv, da der Compiler den String
als Platzhalter zur Laufzeit für die realfunktionierenden Methode nicht auflösen kann.

Ich habe im Forum etwas gesucht und mich am Beitrag
String als Klassenname verwenden

orientiert.
Bisher war ich damit nicht recht weiter gekommen. Dennoch werde ich mich gleich noecheinmal dransetzen und sehen, ob ich es auf mein Problem adaptieren kann.

Mit dem Hinweis von Niki

....
if(obj instanceof MyInterface){
  new Thread(new Runnable(){
    public void run(){
      ((MyInterface)obj).doMyMethod();
    }
  ).start();
}
.....

habe ich Probleme mit dem MyInterface. Genau das will ich als String übergeben und ändert sich je nach
Lösungsweg.

Thomas

 

[ms]

Schau mal hier:

package test;

import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

class TestClass {

    private int j = 0;

    public TestClass(int j) {
        super();
        this.j = j;
    }

    public void doSomething() {
        // Consolenausgabe und kurz warten
        for (int i=1; i<=j; i++) {
            System.out.println(toString() + " : " + i);
            try {
                Thread.sleep(100 * j);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public String toString() {
        return "TestClass" + j;
    }

}

public class ThreadRunner extends Thread {

    private Object object = null;
    private Method method = null;

    public ThreadRunner(Object object, String methodName) {
        super();
        this.object = object;
        if (object != null) {
            try {
                this.method = object.getClass().getDeclaredMethod(methodName, null);
            } catch (SecurityException e) {
                e.printStackTrace();
            } catch (NoSuchMethodException e) {
                e.printStackTrace();
            }
        }
    }

    /* (non-Javadoc)
     * @see java.lang.Thread#run()
     */
    public void run() {
        if (method != null) {
            System.out.println("starting method " + method.getName() + " of object " + object);
            try {
                method.invoke(object, null);
            } catch (IllegalArgumentException e) {
                e.printStackTrace();
            } catch (IllegalAccessException e) {
                e.printStackTrace();
            } catch (InvocationTargetException e) {
                e.printStackTrace();
            }
            System.out.println("method " + method.getName() + " finished of object " + object);
        }
    }


    public static void main(String[] args) {
        new ThreadRunner(new TestClass(4), "doSomething").start();
        new ThreadRunner(new TestClass(8), "doSomething").start();
        TestClass tc = new TestClass(6);
        tc.doSomething();
    }

}

ms

 

[Thomas_java]

Vielen Dank für eure Hinweise.

Hab eure Hinweise etwas geschüttelt und gerührt und dabei ist folgendes (lauffähiges) herausgekommen.

...
  // Aufrufbeispiel:
  if (erg == 1)
      meineFKT("runClass1", "para1a", "para2a");
   else
      meineFKT("runClass2", "para1b", "para2b");
   
....

	public void meineFKT(String threadName, String str1, String str2)
	{
		Class<?> clazz;
		Class<?>[] params;
		final Method  method;
		final Object  obj;
		Object[] aktargs;
		Constructor<?> con;
		try
		{
			clazz = Class.forName(threadName);
			params = new Class[2];
			params[0] = String.class; 
			params[1] = String.class;
			con = clazz.getConstructor(params);
			aktargs = new Object[]{str1, str2};
			obj = con.newInstance(aktargs);
			method = clazz.getMethod("run",(Class<?>[])null);
			new Thread(new Runnable()
			{
				public void run()
				{
					try
					{
						method.invoke(obj,(Object[])null);
					}
					catch(Exception e)
					{
						System.err.println(e.toString());
						System.exit(1);
					}					
				}
			}).start(); 
		}
		catch(Exception e)
		{
			System.err.println(e.toString());
			System.exit(1);
		}
	}

Thomas