如何使用Java线程应用约简函数？

Question

如果我有一个简单的程序来并行计算从0到9的随机整数中的1's数，对于大量的迭代，我如何减少使用sum函数计算1's (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

在Java中，您必须坐下来手动管理事情。换句话说:假设您的数据是分区的，您只需启动这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 );
   }
}