Vlákna - synchronizace – Java – Fórum – Programujte.com

Ahoj,

zkousel jsem si napsat metodu, ktera by mne spocitala za pomoci rekurze fib. cislo.

Akorat nejak nechapu jak synchronizovat vlakna, ktery maji provadet vypocet.

Byl bych rad za nejaky rady co delam spatne a co vubec neresim atd.

predem dekuji   

Prikladam zdrojac: 

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */
package up4jparfibvlakna;

/**
 *
 * @author johny
 */
public class Pokus {

    public static int fib(int n) {
        if (n == 0) {
            return 0;
        }
        if (n == 1) {
            return 1;
        }

        return fib(n - 1) + fib(n - 2);
    }

    public static int parfib(int n, int k) throws InterruptedException {
        Thread[] threads = new Thread[k];

        for (int i = 0; i < k; i++) {
            threads[i] = new Thread(new FibThreed(n));
        }

        for (Thread t : threads) {
            t.start();
        }

        for (Thread t : threads) {
            t.join();
        }
        return FibThreed.getFibNumber();
    }

    /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws InterruptedException {
        System.out.println(parfib(44, 5));
    }

    public static class FibThreed implements Runnable {

        private int n;
        private static int fibNumber = 0;

        public FibThreed(int n) {
            this.n = n;
        }

        @Override
        public void run() {
            fibNumber = fib(n);
        }

        public int getN() {
            return n;
        }

        public static int getFibNumber() {
            return fibNumber;
        }
    }
}

proboha lidi, napřed si to zkuste vyhledat sami, tohle mi našlo jako první link v googlu

http://www.milosnemec.cz/clanek.php?id=204

k tomu se používá klíčový slovo "synchronized" a stručně řečeno je to zámek, kdy zamkneš určitej blok kódu, aby ve stejnej čas byl prováděn jen jednim vláknem

#2 ingiraxo

To jsem si samozřejmě našel, ale nechápu jak můžu jeden výpočet provádět za pomoci k vláken?Jedině to jde tak, že se střídají... a mě nenapadá, (spíš asi nechápu) jak toho docílit?Když jsem se to snažil synchronizovat za pomoci synchronized, tak se mi výpočet provedl napr. 5x, když jsem zadal 5 vláken.   

otázkou je, proč by si jeden výpočet dělal přes několik vláken... vlákno můžeš použít třeba na výpočet 1. kroku výpočtu a na druhej použiješ druhý vlákno a až budou obě vlákna hotová (bude čekat jedno na druhý = synchronizace), tak máš výsledek

#4 ingiraxo
No bylo to tak v zadání co by jsme si měli zkusit.Máme vypočítat n-té fib. č. ,ale k výpočtu máme použít až k vláken.Co ale bude u výpočtu fib. č. první krok 2.,3. atd. ? 

teď si to řekl sám. "vypočítat n-té fib. č.".. každej krok je to "n",.. takže první vlákno si vezme n=1, druhy hned n=2 a to, který skončí dřív, tak n=3 atd.

tady použiješ ten sychronized, páč ten výpočet muže dělat jen jedno vlákno a další musí pokračovat a jít na dalčí vypočet

#6 ingiraxo
Takže jestli jsem to pochopil správě,tak v mainu si vytvořim vlákna pro zkoušku 2. 

	Thread vlakno1 = new FibThreed(n);
        vlakno1.start();
        Thread vlakno2 = new FibThreed(n);
        vlakno2.start();

a dále mám nějakou třídu public static class FibThreed extends Thread {..}, u které přepíšu metodu run() ,ve které volám metodu pro výpočet fib. č. .

synchronized private int fib(int n) {
            if (n == 0) {
                return 0;
            }
            if (n == 1) {
                return 1;
            }
            return fib(n - 1) + fib(n - 2);
        }

Ale teď mně každé vlákno ten výpočet provede samotné pokud se nemýlím?Teď jsem skončil na tom jak je sesynchronizovat aby provedli jeden a tentýž výpočet jakoby společně...

Zrovna tam je to synchronized k ničemu.

Mám takový pocit, že si to představuješ tak, že napíšeš funkci a vlákna si nějak automaticky práci té funkce mezi sebe rozdělí, každé udělá část a výsledek se zase nějak spojí. Takhle to nefunguje, každé vlákno prostě něco dělá, ve tvém případě všechny dělají to samé od začátku až do konce. To rozložení úkolu na části a rozdělení mezi vlákna musíš naprogramovat.

Synchronizace pak spočívá ve sladění a spolupráci těch vláken. Jako aby několik vláken neměnilo nějakou hodnotu současně, nebo aby se nenačítala data, která se zrovna jinde mění a nejsou v konzistentním stavu, nebo aby vlákno závislé na výsledku jiného vlákna počkalo až ten výsledek bude k dispozici a případně mezitím dělalo něco jiného apod.

Vlastně už to ingiraxo napsal, ale připadá mi, že tu podstatu nechápeš.

#8 zlz
Jo měl jsem v tom zmatek, ale už to snad mám ujasněny.

Děkuji.