Java ForkJoinPoolは私が期待したことをしていません

Question

私はJavaのForkJoinPoolについて学んでいます。より良いレベルの理解を得るために、私は自分自身のための小さな例を作りました。私は、出力を生成するために書いたコードを期待していますが、コンソールウィンドウに何も表示されません。エラーはないので、このサービスの使い方を誤解している可能性があります。メソッドが何をしているのかを正確に記述していないメソッド名は無視してください。これは結局のところスクラッチコードです。また

import java.util.concurrent.RecursiveAction; 

public class SortTask extends RecursiveAction { 
    final int THRESHOLD = 10; 
    int[] array; 
    int begin, end; 

    public SortTask(int[] array, int begin, int end) { 
     this.array = array; 
     this.begin = begin; 
     this.end = end; 
    } 

    @Override 
    protected void compute() { 
     if((end - begin) < THRESHOLD) { 
      for(int i = 0; i < array.length; i++) { 
       System.out.println(i); 
       array[i] = i; 
      } 
     } else { 
      int middle = (end - begin)/2; 
      invokeAll(new SortTask(array, begin, middle), new SortTask(array, begin, middle)); 
      merge(array, begin, end); 
     } 
    } 

    public void merge(int[] array, int begin, int end) { 
     System.out.println(array.length); 
    } 
} 

：

ForkJoinタスクが実際に起こって開始する前に、あなたのJavaプログラムが終了している

import java.util.concurrent.ForkJoinPool; 

    public class Main { 

     public static void main(String[] args) { 
      System.out.println(Runtime.getRuntime().availableProcessors()); 
      int[] list = new int[1000]; 
      SortTask st = new SortTask(list, 0, 999); 
      ForkJoinPool pool = new ForkJoinPool(); 
      pool.execute(st); 
     } 
    } 

Answer 1

。タスクが完了した後に、の代わりにinvokeを使用して、タスクの完了後に「待機」する必要があります。

pool.invoke(st);