forjointaskでAtomiceIntegerが期待どおりに増加していません

Question

AtmoicIntegerをフォークジョイント内部で使用して、開始条件に何回もカウントしていますが、AtomicIntegerは決してincrementAndGet（）で更新されませんでした。

package Chapter7; 

import java.util.concurrent.ForkJoinPool; 
import java.util.concurrent.ForkJoinTask; 
import java.util.concurrent.RecursiveAction; 
import java.util.concurrent.atomic.AtomicInteger; 
@SuppressWarnings("serial") 
public class PrcForkJoinTask extends RecursiveAction { 
    private int start , end; 
    AtomicInteger count = new AtomicInteger(0); 
    public PrcForkJoinTask(int start, int end){ 
     this.start = start; 
     this.end = end; 
    } 
    @Override 
    protected void compute() { 
     // TODO Auto-generated method stub 
     if(end - start <= 2){ 
      System.out.println("close condition reached" + "Start is " + start + "end is " + end) ; 
      System.out.println("calculated times" + count.getAndIncrement()); 
      } 
    else{ 
     int middle = start + ((end - start)/2); 
     System.out.println("middle is " + middle) ; 
     invokeAll(new PrcForkJoinTask(start,middle),new PrcForkJoinTask(middle,end)); 

      }  
    } 


    public static void main(String[] args){ 

     ForkJoinTask<?> fs = new PrcForkJoinTask(0,10); 

     ForkJoinPool pool = new ForkJoinPool(); 

     pool.invoke(fs);  
    } 
} 

Answer 1

たびライン

invokeAll(new PrcForkJoinTask(start,middle),new PrcForkJoinTask(middle,end)); 

で再帰にそれが新しいのAtomicIntegerカウント= 0で新しいオブジェクトを作成し、それがため、複数の行で1

System.out.println("calculated times" + count.getAndIncrement()); 

によって増加されます新しいオブジェクトPrcForkJoinTaskが作成され、それぞれがcount = 1を持ちます

新しいPrcForkJoinTaskオブジェクトの内部でカウントする必要がある要約を計算します。