シンプルなjavaパラレルプログラム

Question

パラレルプログラミングに精通するために、4つのスレッドを使用して配列のすべての要素の合計を計算する簡単なjavaパラレルプログラムを作成したかったのです。ここで

は、Threadクラスを拡張することSumClassです：

public class SumThread extends Thread { 
int lo; 
int ho; 
int Arr[]; 
int ans=0; 

//constructor 
SumThread(int Arr[], int lo, int ho){ 
    this.Arr = Arr; 
    this.lo = lo; 
    this.ho = ho; 
} 

public void run(){ 
    for (int i=lo; i<ho; i++){ 
     ans += Arr[i]; 
    } 
    } 
} 

そして、ここで私たちはメインクラスを持っている：

public static void main(String[] args) { 
    // TODO Auto-generated method stub 
    int Arr[] = { 1, 3, 4, 5, 5, 6, 7, 2, 7, 5, 2, 4 }; 
    int ans = 0; 

    SumThread[] sum = new SumThread[4]; 

    for (int i = 0; i < 4; i++) { 
     sum[i] = new SumThread(Arr, (i * Arr.length)/4, Arr.length * ((i + 1)/4)); 
     sum[i].start(); 

    } 

    for (int i = 0; i < 4; i++) { 
     try { 
      sum[i].join(); 
     } catch (InterruptedException ex) { 
      ex.printStackTrace(); 
     } 

    } 
    for (int i = 0; i < 4; i++) { 
     ans += sum[i].ans; 
    } 

    System.out.println(ans); 

    } 

} 

私は待つために参加する（）関数を使用しましたans値にアクセスして印刷する前に終了するスレッド。 ポイントは私が結果として11を得て、それは完全に間違っています。私はそれが最後の3つの値（5,2,4）だけを合計することに気づいた。 4番目のスレッドだけが起動するようです。

私は間違っていますか？

Answer 1

スレッドセーフはありません。どのようにデータを渡すかです。 ExecutorServiceを使用すると、少なくともFutureを介して渡される戻り値はスレッドセーフになりますが、組み込みのストリームAPIを使用し、このコードをすべて2-3行に置き換えることができます。

int[] array = { 1, 3, 4, 5, 5, 6, 7, 2, 7, 5, 2, 4 }; 
int sum = IntStream.of(array).parallel().sum(); 
System.out.println(sum); 

または

System.out.println(IntStream.of(1, 3, 4, 5, 5, 6, 7, 2, 7, 5, 2, 4).parallel().sum()); 

Answer 2

これはあなたに51を与える必要があります

public static void main(String[] args) { 
    // TODO Auto-generated method stub 
    int Arr[] = { 1, 3, 4, 5, 5, 6, 7, 2, 7, 5, 2, 4 }; 
    int ans = 0; 

    SumThread[] sum = new SumThread[4]; 

    for (int i = 0; i < 4; i++) { 
     sum[i] = new SumThread(Arr, (i * Arr.length)/4, (Arr.length * (i + 1))/ 4); 
     sum[i].start(); 
    } 

    for (int i = 0; i < 4; i++) { 
     try { 
      sum[i].join(); 
     } catch (InterruptedException ex) { 
      ex.printStackTrace(); 
     } 
    } 
    for (int i = 0; i < 4; i++) { 
     ans += sum[i].ans; 
    } 

    System.out.println(ans); 
} 

}