Java并行流处理时间不匹配

Question

在我的windows机器上，我有6个内核。

我创建了一个24个元素的流，并使用stream API中的map操作对每个元素执行一个操作。我利用了并行性：

myCollection.parallelStream()
                    .map(element -> someTimeConsumingOperation(element)
                    .collect(toList());

someTimeConsumingOperation使用以下命令模拟长操作：

Thread.sleep(2000);

myCollection有24个元素。据我所知，streams使用默认的ForkJoinPool executor来并行运行操作，这反过来又会考虑核心的数量，以确定池中有多少线程。

因为有6个核心，所以我假设最多创建6个线程。如果是这种情况，并且每个操作几乎需要2秒，那么整个流处理必须花费大约8秒(每个线程将执行4个操作，因为我们有24个元素要处理，因此是4*2秒)。

但我观察到处理过程只需要4秒。

Answer 1

您的6核英特尔处理器已启用HyperThreading。使用HT，操作系统和应用程序将每个CPU核心视为两个独立的“逻辑核心”或“线程”(术语各不相同)。这意味着ForkJoinPool将使用12个线程，而不是6个。

“逻辑核心”彼此之间共享一些资源，因此并行运行12个任务不会提供两倍于运行6个任务的吞吐量。但是，只调用sleep()的程序不会知道其中的区别。