Thread - Problem

[MFM]

Hi, ich hatte schon einmal ein Thema eröffnet, es ging darum, dass zu einem Array, welches Integerzahlen enthält, die jeweiligen Fibonacci-Zahlen berechnet werden sollen. Zwar in einem separaten Thread für jede Fibozahl

Hier einmal der Code:

public class FibCalc {

	// tmp-Array für die MultiThreadingMethode
	static int[] mtArray;
	// Thread/Feldcounter für die MultiThreadingMethode
	static int cnt;

	public static int fib(int n) throws FibException {

		// Fehlerbehandlung
		if (n < 0 || n > 40) {
			throw new FibException(n);
		}

		int fibonacci;

		// AbbruchBedingungen
		if (n == 0) {
			return 0;
		}

		if (n == 1) {
			return 1;
		}

		// Rekursionsschritt
		else {
			return fibonacci = fib(n - 1) + fib(n - 2);
		}
	}



	public static int[] fibMT(int numberArray[]) {

		mtArray = new int[numberArray.length]; // <<<--- Liegt hier der Hund begraben??

		// kopiere das übergebene Array in das statische mtArray
		System.arraycopy(numberArray, 0, mtArray, 0, numberArray.length);

		for (int i = 0; i < mtArray.length; i++) {
			cnt = i;
			new Thread(new Runnable() {
				public void run() {
					try {
						mtArray[cnt] = FibCalc.fib(mtArray[cnt]);
					} catch (FibException e) {
						mtArray[cnt] = -1;
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}

			}).start();
		}
		return mtArray;
	}
}

Mal davon abgesehen, dass ich nicht weiß, wie das ohne Klassenvariablen gehen soll und das noch nicht synchronisiert ist ...

Wenn ich an die Methode ein Array mit Integerzahlen wie hier in der Testklasse übergebe
, dann passiert da rein garnix

public class TestKlasse {

	public static void main(String[] args) {
		
		int[] array = {40,40,40,40,40,40};
		
		array = FibCalc.fibMT(array);
		
		
		for (int i=0; i<array.length; i++){
			System.out.println(array[i]);
		}

	}

}

Er gibt mir 40,40,40,40,40,40 aus anstatt irgendne Zahl > 1 Mio ...

Liegt es evtl an der ersten Zeile in der fibMT?
mtArray = new int[numberArray.length]; ? Kann es sein, dass hier ein IntArray Objekt angelegt wird, welches rein garnix mit meinem mtArray zu tun hat?

Wie schaffe ich es dann, den übergebenen Array in mtArray zu kopieren?

Wäre echt super, wenn mir jemand helfen könnte
MFM[/code]

 

[SlaterB]

die Kopie ist gelungen, die Ausgabe erfolgt aber sofort, während die Threads erst paar Sekunden brauchen, um die Zahlen zu berechnen

hier ein paar Verbesserungen, da wäre aber noch viel zu tun,

wichtig: das cnt setzt du ganz falsch ein, am Ende der Schleife ist cnt = mtArray.length-1
und alle Thread verwenden den aktuellen Wert von cnt, nicht den den es irgendwann zwischendurch mal innehatte,

wieso verwendest du überhaupt Threads?
das scheint noch etwas zu kompliziert für dich

public class Test
{
    public static void main(String[] args)
        throws Exception
    {
        int[] array = {40, 40};

        array = FibCalc.fibMT(array);


        for (int i = 0; i < array.length; i++)
        {
            System.out.println(array[i]);
        }
        Thread.sleep(6000);

        for (int i = 0; i < array.length; i++)
        {
            System.out.println(array[i]);
        }

    }
}


class FibCalc
{


    public static int fib(int n)
        throws Exception
    {
        // Fehlerbehandlung
        if (n < 0 || n > 40)
        {
            throw new Exception("" + n);
        }

        // AbbruchBedingungen
        if (n < 2)
        {
            return n;
        }
        // Rekursionsschritt
        return fib(n - 1) + fib(n - 2);
    }


    public static int[] fibMT(int numberArray[])
    {

        final int[] mtArray = new int[numberArray.length]; // kein Hund begraben

        // kopiere das übergebene Array in das statische mtArray
        System.arraycopy(numberArray, 0, mtArray, 0, numberArray.length);

        for (int i = 0; i < mtArray.length; i++)
        {
            final int threadI = i;
            new Thread(new Runnable()
                {
                    public void run()
                    {
                        System.out.println(System.currentTimeMillis() + ", Thread " + 
                                            threadI + " startet");
                        try
                        {
                            mtArray[threadI] = FibCalc.fib(mtArray[threadI]);
                        }
                        catch (Exception e)
                        {
                            mtArray[threadI] = -1;
                            e.printStackTrace();
                        }
                        System.out.println(System.currentTimeMillis() + ", Thread " + 
                                           threadI + " ist fertig");
                    }

                }).start();
        }
        return mtArray;
    }
}

 

[MFM]

Werde den Thread nicht pflegen können, da ich bis 18.30 wieder in Vorlesung hocke, also bitte nicht echauffieren, dass ich nen Thread aufmache und nicht antworte.

Bin dennoch für jede zwischenzeitliche Antwort sehr dankbar.

MFM

P.S.:

bezügl. Threads ... das ist eine Vorgabe, da ist nix zu rütteln.
Und das mit dem zeitlichen synchronisieren Das wollte ich als nächstes machen. Habe nicht daran, dass es wirklich auch nur daran liegen könnte. Normalerweise teste ich immer wieder, nachdem ich einen "Schritt" weiterprogrammiert habe, bevor ich mich an den nächsten wage ...



Wie gesagt, bis später.

Danke schon mal im Voraus.

 

[MFM]

hat sich vorerst mal erledigt.

Prof meinte ich solle das nicht mit anonymen Klassen machen, wenn ich ihm nicht genau erklären könne, was das Konstrukt genau macht

Werde es anders lösen

Danke SlaterB