Java 스레드에서 reduce 함수를 적용하는 방법은 무엇입니까?

Question

많은 수의 반복에 대해 0부터 9까지의 임의의 정수에서 1의 수를 계산하는 간단한 프로그램이있는 경우 sum 함수를 사용하여 1의 (numOnes)를 계산하는 변수를 어떻게 줄일 수 있습니까? 나중에 내 프로그램에서 총계를 사용할 수 있어야합니다.

이것은 OpenMP의 감소 지시문과 동일합니다.

public void run() { 

    long work = total_iterations/threads; 
    long numOnes = 0; 

    for (long i = 0; i < work; i++) { 
    int randomNum = rand.nextInt(9); 

    if (randomNum == 1) { 
     numOnes += 1; 
    } 
    } 
} 

각 스레드가 실행 완료되면 집계 결과가 포함 된 numOnes를 사용할 수 있기를 원합니다.

Answer 1

자바에서는 수동으로 앉아서 관리해야합니다. 즉, 데이터가 분할되었다고 가정하면이 10 개의 스레드를 걷어 차서 작업을 수행 할 수 있습니다.

결국, 당신은 join 모든 스레드를 원합니다; 모든 스레드가 "결합"된 경우에만; 그들 모두는 행해진 다. 당신은 그 결과를 처리하고 진행할 준비가되어 있습니다.

또는 ExecutorService 및 Futures와 같은 "추상"항목을 살펴보아야합니다. "베어 메탈"스레드를 직접 다루지 않아도됩니다.

물론 꽤 일반적입니다. 그러나 잘, 당신의 질문입니다.

Answer 2

여기에 스트림을 사용할 수 있습니다.

public class ParallelInts 
{ 
    public static void main(String[] args) { 
     int count = new Random().ints(1_000_000, 0, 10).parallel() 
       .reduce(0, (sum, i) -> sum + ((i==1)?1:0)); 
     System.out.println("count = " + count); 
    } 
}