在ParallelStream中使用java AtomicReference线程是否安全？
public static void main(String[] args) {
AtomicReference<String> longest = new AtomicReference<>();
LongAccumulator accumulator = new LongAccumulator(Math::max, 0);
List<String> words = Arrays.asList("him", "he", "thanks", "strings", "congratulations", "platform");
words.parallelStream().forEach(
next -> longest.updateAndGet(
current -> {
String result = next.length() > accumulator.intValue() ? next : current;
accumulator.accumulate(next.length());
return result;
}
)
);
System.out.println(longest.get());
}
有一次，我被印上了“祝贺”，有一次，我被印上了“站台”。
共有1个答案
您正在调用longexculator.intvalue()，其文档如下：
在缩小基元转换后以int形式返回当前值。
通过链接到get()方法，我们将了解到：
-
我有一个在Oracle 11g DB上运行的insert语句，如下所示： 这里有一个处理PostgreSQL的类似问题。但是，由于Oracle序列由所有会话共享，所以我不能相信DB会给出当前会话中最后插入的值。
-
问题内容： 我一直在假设线程安全也不是线程安全，但是在最近的一次讨论中，一位同事告诉我线程安全。 因此，我做了一些研究，却一无所获。很多人认为它是线程安全的，很多人认为它不是线程安全的。而且，最重要的是，文档没有以一种或另一种方式说任何话，不是为了，甚至不是。 那是什么呢？ 问题答案： 这是指向Java 7 中Calendar和GregorianCalendar的源代码的链接。 如果阅读该代码，您
-
问题内容： 我知道文档说明该对象是线程安全的，但这是否意味着从所有方法对其进行的所有访问都是线程安全的？因此，如果我一次从多个线程中调用它，并且一次在同一实例上调用它，会不会发生什么不好的事情？ 问题答案： 快速答案是肯定的，它们是线程安全的。但是不要让它在那里… 首先，一个小的内部管理是一个接口，任何不是线程安全的实现都将破坏书面合同。您包括的链接是指，它具有一定的灵巧性。 您包含的链接引起了一
-
问题内容： 我决定使自己熟悉node.js，并阅读有关该主题的几篇文章。我仍然不清楚的是，当您调用node.js函数时，node.js是否在线程池中创建新线程和/或在线程上调度任务。 例如，如果我调用它是否在其他线程上执行？ 如果是，[如何]我可以编写自己的函数或在其他线程上运行？ 问题答案： 没有用于文件操作的异步API，因此node.js为此使用了线程池。您可以在libuv的代码中看到它。 该
-
null 有些问题似乎是这样说的： 如何为多个用户隔离Jetty HttpClient？
-
在JDK8中，当我使用ParallelStream时会生成多少线程？例如，在代码中： 如果这个列表有100000个项目，那么会产生多少个线程？ 另外，是每个线程都得到相同数量的项目来工作，还是随机分配？