Java8Parallel stream+anyMatch-线程一旦找到匹配就会中断吗？

Question

如果我在Java8中有一个并行流，并且我以anyMatch终止，并且我的集合有一个与谓词匹配的元素，那么我将试图弄清楚当一个线程处理这个元素时会发生什么。

我知道anyMatch是短路的，这样我就不会期望一旦匹配元素被处理，就会有更多的元素被处理。我的困惑是其他线程会发生什么，这些线程大概处于处理元素的中间。我可以想到3种可能的场景：a）它们是否被中断？b）它们是否继续处理它们正在处理的元素，然后，当所有线程都不做任何事情时，我得到了结果？c）我得到了结果，但正在处理其他元素的线程继续处理这些元素（但在其他元素完成后，它们不再处理这些元素）？

我有一个长时间运行的谓词，在这里，只要我知道一个元素匹配就快速终止是非常有用的。我有点担心，因为我在文档中找不到这可能是一个依赖于实现的东西的信息，这也是很好的了解。

谢谢

Answer 1

在仔细研究了Java源代码之后，我想我找到了答案。

其他线程定期检查另一个线程是否找到了答案，如果找到了答案，则停止工作并取消任何尚未运行的节点。

java.util.stream.findops$FindTask具有以下方法：

private void foundResult(O answer) {
        if (isLeftmostNode())
            shortCircuit(answer);
        else
            cancelLaterNodes();
    }

 /**
 * Declares that a globally valid result has been found.  If another task has
 * not already found the answer, the result is installed in
 * {@code sharedResult}.  The {@code compute()} method will check
 * {@code sharedResult} before proceeding with computation, so this causes
 * the computation to terminate early.
 *
 * @param result the result found
 */
protected void shortCircuit(R result) {
    if (result != null)
        sharedResult.compareAndSet(null, result);
}

 AtomicReference<R> sr = sharedResult;
    R result;
    while ((result = sr.get()) == null) {
        ...//does the actual fork stuff here
    }

1. 线程不中断
2. 相反，他们将定期检查是否有人找到了答案，如果找到了答案，将停止进一步的处理。
3. 一旦找到答案，将不会启动任何新线程。