Thread

[Adriano10]

    public void createForXMLFile(File[] files) throws Exception {


        Thread thread = new Thread(() -> {
            File[] files1 = new File[files.length / 4];
            int count = 0;
            for (int j = 0; j < files.length / 4; j++) {
                files1[count++] = files[j];
                if (count == files1.length) {
                    break;
                }

            }
            try {
                Document doc = merge("/Bestellung/", files1);
                write(doc);
            } catch (Exception e) {
            }
        });

        Thread thread1 = new Thread(() -> {
            File[] files2 = new File[files.length / 4];
            int count = 0;
            for (int j = files.length / 4; j < files.length / 2; j++) {
                files2[count++] = files[j];
                if (count == files2.length) {
                    break;
                }
            }
            try {
                Document doc = merge("/Bestellung/", files2);
                write(doc);
            } catch (Exception e) {
            }

        });

        Thread thread2 = new Thread(() -> {
            File[] files3 = new File[files.length / 4];
            int count = 0;
            for (int j = files.length / 2; j < files.length; j++) {
                files3[count++] = files[j];
                if (count == files3.length) {
                    break;
                }
            }
            try {
                Document doc = merge("/Bestellung/", files3);
                write(doc);
            } catch (Exception e) {
            }
        });
        Thread thread3 = new Thread(() -> {
            int help = 0;
            final int i = files.length - (files.length / 4) * 3;
            File[] files4 = new File[i];
            help = files.length - i;
            int count = 0;
            for (int j = help; j < files.length; j++) {
                files4[count++] = files[j];
                if (count == files4.length) {
                    break;
                }
            }
            try {
                Document doc = merge("/Bestellung/", files4);
                write(doc);
            } catch (Exception e) {
            }
        });
        thread.start();
        thread1.start();
        thread2.start();
        thread3.start();
        thread.join();
        thread1.join();
        thread2.join();
        thread3.join();
    }

Guten Tag liebe Leute,

Ich mach Einstieg in Thread, daher wollte gern fragen, ob ich hier alles richtig gemacht habe.

Also wenn ich diese Method aufrufe, macht alles was gewünscht ist, aber mit Thread hatte ich vorher nicht viele Erfahrung. Daher wenn euch irgendwas auffällt, was ich nicht sehen kann, und mir Anmerkungen geben, würde ich so verbessern...

Vielen Dank im Voraus

 

[mihe7]

In Bezug auf die Threads sieht das prinzipiell nicht falsch aus (wobei die Berechnung in thread3 etwas kompliziert anmutet). Das Problem lässt sich gut und einfach parallelisieren, weil es in disjunkte Teilprobleme geteilt werden kann.

Allerdings hast Du mehrfach den gleichen Code im Programm stehen, der sich nur im von-/bis-Index unterscheidet: mach 'ne Klasse draus und erzeuge Instanzen davon (EDIT: und verwende System.arraycopy).

 

[Adriano10]

Okay gute Anmerkungen, ich versuche dann mal, Code so zu gestalten.
Vielen Dank

 

[Adriano10]

In Bezug auf die Threads sieht das prinzipiell nicht falsch aus (wobei die Berechnung in thread3 etwas kompliziert anmutet). Das Problem lässt sich gut und einfach parallelisieren, weil es in disjunkte Teilprobleme geteilt werden kann.

Allerdings hast Du mehrfach den gleichen Code im Programm stehen, der sich nur im von-/bis-Index unterscheidet: mach 'ne Klasse draus und erzeuge Instanzen davon (EDIT: und verwende System.arraycopy)

Was die Berechnung angeht, die gegeben Menge sind immer unterschiedlich, die ich dann in vier Array aufteilen muss… wie könnte man einfacher schreiben. Mir kommt mehr keine Idee, im Bezug auf die Berechnung

 

[mihe7]

Eine Möglichkeit: Du willst x Threads verwenden, daher teilst Du ein Array der Größe n in x Teile. Die ganzzahlige Division n/x ergibt somit die Zahl der Elemente eines Teils, wobei der letzte Teil größer sein kann.

Skizze:

Thread[] threads = new Threads[4];
int m = files.length / threads.length; 
for (int i = 0; i < threads.length; i++) {
    int from = m*i;
    int to = (i+1 == threads.length) ? files.length : from + m;
    threads[i] = new Thread(new Worker(files, from, to));
    threads[i].start();
}

for (int i = 0; i < threads.length; i++) {
    threads[i].join();
}

 

[Adriano10]

Eine Möglichkeit: Du willst x Threads verwenden, daher teilst Du ein Array der Größe n in x Teile. Die ganzzahlige Division n/x ergibt somit die Zahl der Elemente eines Teils, wobei der letzte Teil größer sein kann.

Skizze:

Thread[] threads = new Threads[4];
int m = files.length / threads.length;
for (int i = 0; i < threads.length; i++) {
    int from = m*i;
    int to = (i+1 == threads.length) ? files.length : from + m;
    threads[i] = new Thread(new Worker(files, from, to));
    threads[i].start();
}

for (int i = 0; i < threads.length; i++) {
    threads[i].join();
}

Das klingt mir sehr interessant, ich versuch mal… Vielen Dank, sehr hilfreich

 

[mrBrown]

Sowas:

catch (Exception e) {
}

sollte aber niemals irgendwo benutzt werden.

Und write(doc); in jedem Thread kann problematisch werden, wenn da etwas da passiert was nicht mehrmals gleichzeitig passieren darf, zB in eine Datei zu schreiben

 

[mihe7]

Und write(doc); in jedem Thread kann problematisch werden, wenn da etwas da passiert was nicht mehrmals gleichzeitig passieren darf, zB in eine Datei zu schreiben

Das sind immer unterschiedliche Dateien (wenn ich mich recht entsinne, ist es bei ihm die erste Datei im bereits aufgeteilten Array).

 

[Adriano10]

Das sind immer unterschiedliche Dateien (wenn ich mich recht entsinne, ist es bei ihm die erste Datei im bereits aufgeteilten Array).

Richtig, das ist so