简单的多线程Java app-ExecutorService？分叉/连接？分离器？

Question

我正在用Java 8编写一个命令行应用程序。有一部分涉及一些计算，我相信使用多个线程并行运行可能会带来好处。然而，我在编写多线程应用程序方面没有太多经验，因此我希望您能引导我朝着正确的方向前进，我应该如何设计代码的并行部分。

为了简单起见，让我们假设所讨论的方法接收到一个相对较大的长数组，它应该返回一个只包含素数的集：

public final static boolean checkIfNumberIsPrime(long number) {
  // algorithm implementation, not important here
  // ...
}

// a single-threaded version
public Set<Long> extractPrimeNumbers(long[] inputArray) {
  Set<Long> result = new HashSet<>();
  for (long number : inputArray) {
    if (checkIfNumberIsPrime(number)) {
      result.add(number);
    }
  }
  return result;
}

现在，我想重构方法提取PrimeNumbers（），使其由四个线程并行执行，当所有线程都完成时，返回结果。在我的脑海中，我有以下问题：

• 哪种方法更适合该任务：ExecutorService还是Fork/Join？（inputArray[]的每个元素都是完全独立的，它们可以以任何顺序处理）
• 假设inputArray[]中有100万元素，我应该“要求”线程#1处理所有索引0...249999、线程#2 - 250000..499999、线程#3 - 500000..749999和线程#4 - 750000..999999吗？或者我应该将inputArray[]的每个元素视为一个单独的任务来排队，然后由适用的工作线程执行？
• 如果检测到素数，则应将其添加到“设置结果”中，因此它需要是线程安全的（同步的）。所以，也许最好每个线程都保持自己的本地结果集，并且只有在它完成时，它才会将其内容一次性传输到全局结果？
• Spliterator在这里有任何用处吗？它们应该用于以某种方式对inputArray[]进行分区吗？

Answer 1

不要使用这些。并行流将足以比您列出的任何备选方案更直接地处理这个问题。

return Arrays.parallelStream(inputArray)
  .filter(n -> checkIfNumberIsPrime(n))
  .boxed()
  .collect(Collectors.toSet());