호출 가능 스레드 풀

Question

호출 가능 스레드 풀 메소드를 사용했습니다. 배열의 큰 숫자를 찾으려고합니다. 발생 빈도가 너무 많아서 모든 것을했으나 오류가 나타납니다. 누구나 나를 도울 수 있습니다. 고맙습니다. 하나 이상

import java.util.concurrent.Callable; 
public class CallableMethod im``plements Callable<Integer>{ 

    //@SuppressWarnings("unused") 
    private int[] num; 

    public CallableMethod(int [] num){ 
     this.num = num; 
    } 

    public Integer call() throws Exception{ 

     int n = num[0]; 
     int frequency = 0; 

     for(int i=1; i< num.length; i++) 
     { 

       if(n < num[i]){ 
         n = num[i]; 
       } 
     } 

     for(int i = 1; i< num.length; i++){ 
      if (n == num[i]){ 
       frequency++; 
      } 
     } 

     //System.out.println("Largest Number is : " + num); 
     //System.out.println("frequency of occurence : " + frequency); 
     return frequency; 
    } 
} 

이 하나가 내 ThreadPool이 내 callabe() 코드와

import java.util.concurrent.*; 
import java.util.*; 

class ThreadPoolMethod { 
    // static ExecutorService pool = Executors.newFixedThreadPool(2); 

    public static void main(String[] args) { 
     ThreadPoolExecutor pool = (ThreadPoolExecutor) Executors.newFixedThreadPool(2); 
     int number[] = { 32, 43, 145, 53, 25, 98, 54, 32, 65, 63, 145, 98, 43, 23, 25, 98, 100, 102, 105, 123, 145, 
       122, 123, 11, 12, 1, 0, 123, 145, 145 }; 
     ArrayList<Future<Integer>> future = new ArrayList<Future<Integer>>(); 
     for (int j = 0; j < number.length; j++) { 
      Future<Integer> f = pool.submit(new CallableMethod(number)); 
      future.add(f); 
     } 
     // create array to store results 
     int result[] = new int[number.length]; 
     for (int j = 0; j < result.length; j++) { 
      try { 
       Future<Integer> f = future.get(j); 
       result[j] = f.get(); 
      } catch (InterruptedException e) { 
      } catch (ExecutionException e) { 
      }; 
     } 
     System.out.println("The Large Number in array is: " + n); 
     System.out.println("The : " + frequency); 
     pool.shutdown(); 
     for(int x : result) 
      System.out.print(x); 
    } 
} 

입니다. 제발 당황 스러워요. 나는 나에게 스트림, CompletableFuture와 자바 8이 예제를 사용하는

Answer 1

시도 도움이 ThreadPool이 method.Please에

import java.util.ArrayList; 
import java.util.List; 
import java.util.concurrent.CompletableFuture; 
import java.util.concurrent.ForkJoinPool; 
import java.util.stream.Collectors; 


public class DemoController { 

    public static void main(String[] args) { 
     ForkJoinPool forkJoinPool = new ForkJoinPool(2); 
     int number[] = {32, 43, 145, 53, 25, 98, 54, 32, 65, 63, 145, 98, 43, 23, 25, 98, 100, 102, 105, 123, 145, 
       122, 123, 11, 12, 1, 0, 123, 145, 145}; 
     List<CompletableFuture<Integer>> future = new ArrayList<>(); 
     for (int j = 0; j < number.length; j++) { 
      CompletableFuture<Integer> f = CompletableFuture.supplyAsync(() -> func(number), forkJoinPool); 
      future.add(f); 
     } 
     List<Integer> result = future.stream().map(f -> { 
      try { 
       return f.get(); 
      } catch (Exception e) { 
       throw new RuntimeException(e); 
      } 
     }).collect(Collectors.toList()); 
     forkJoinPool.shutdown(); 
     result.forEach(System.out::println); 
    } 

    private static Integer func(int num[]) { 
     int n = num[0]; 
     int frequency = 0; 
     for (int i = 1; i < num.length; i++) { 
      if (n < num[i]) { 
       n = num[i]; 
      } 
     } 
     for (int i = 1; i < num.length; i++) { 
      if (n == num[i]) { 
       frequency++; 
      } 
     } 
     System.out.println("Largest Number is : " + n); 
     System.out.println("frequency of occurence : " + frequency); 
     return frequency; 
    } 
} 

ForkJoinPool을 호출 작업을 호출하지 못할