Java多線程 - 使用Fork-Join方法在列表中查找最大元素

Question

我正在刷新我在Java中的多線程技能並實現了這個簡單的劃分&征服方法在列表中查找最大元素，使用來自java.util.concurrent.ForkJoinTask的RecursiveTask

public static void main(String[] args){ 
    new Multithreading().compute(); 
} 

public void compute(){ 
    Integer[] ints = {3,2,5,7,1}; 
    List<Integer> list = Arrays.asList(ints); 

    ForkJoinPool pool = new ForkJoinPool(); 
    Integer result = pool.invoke(new DividerTask(list)); 
    System.out.println(result); 
} 

class DividerTask extends RecursiveTask<Integer>{ 
    List<Integer> list; 

    public DividerTask(List list){ 
     this.list = list; 
    } 
    @Override 
    protected Integer compute(){ 
     if(list.size() > 2){ 
      int mid = list.size()/2; 
      List<Integer> list1 = list.subList(0,mid); 
      List<Integer> list2 = list.subList(mid,list.size()); 

      DividerTask dt1 = new DividerTask(list1); 
      dt1.fork(); 

      DividerTask dt2 = new DividerTask(list2); 
      dt2.fork(); 

      Integer res1 = dt1.join(); 
      Integer res2 = dt2.join(); 

      return (res1 > res2 ? res1 : res2); 
     } 

     if(list.size() == 2){ 
      Integer res1 = list.get(0); 
      Integer res2 = list.get(1); 

      return (res1 > res2 ? res1 : res2); 
     } 

     return list.get(0); 
    } 
} 

你會如何處理這個問題？你會考慮哪些其他多線程解決方案？

Answer 1

按照例如RecursiveTask：

dt1.fork() 
return dt2.compute() + dt1.join() 

雙連接（）你正在做的結果在這兩個計算等。使用dt2.compute（）強制當前線程繼續移動。