并行流要比java中的流花费更多的时间[duplicate]

Question

我在学习java stream api时在代码中发现了这个问题。

这是我的代码

 long s = System.currentTimeMillis();
 IntStream.range(1, 10).parallel().forEach( x ->{
      System.out.println( "Thread -> "+ Thread.currentThread().getName() +" "+ x );
 });
 long e = System.currentTimeMillis();
 System.out.println("Time taken "+ (e-s) + " ms");

 System.out.println("---------------------");

 s = System.currentTimeMillis();
 IntStream.range(1, 10).forEach( x ->{
     System.out.println( "Thread -> "+ Thread.currentThread().getName() +" "+ x );
 });
 e = System.currentTimeMillis();
 System.out.println("Time taken "+ (e-s) + " ms");

Thread -> main 6
Thread -> ForkJoinPool.commonPool-worker-7 2
Thread -> ForkJoinPool.commonPool-worker-7 5
Thread -> ForkJoinPool.commonPool-worker-13 1
Thread -> ForkJoinPool.commonPool-worker-11 4
Thread -> ForkJoinPool.commonPool-worker-3 3
Thread -> ForkJoinPool.commonPool-worker-15 9
Thread -> ForkJoinPool.commonPool-worker-9 7
Thread -> ForkJoinPool.commonPool-worker-5 8
Time taken using parallel stream 29 ms
-------------------------------------
Thread -> main 1
Thread -> main 2
Thread -> main 3
Thread -> main 4
Thread -> main 5
Thread -> main 6
Thread -> main 7
Thread -> main 8
Thread -> main 9
Time taken simple stream 1 ms

我在sts和inteliJ IDE上试用了这段代码，结果都是一样的。并行比顺序需要更长的时间。我的JDK有问题吗？请建议。

Answer 1

首先，做这种标杆是辛苦的。在代码执行期间执行各种优化。但在这种情况下，当基准本会是好的时，我不会期望有多大不同的结果。

首先，并行化会造成开销。您需要启动和停止线程，有时在某些点上同步线程，在线程之间进行通信，等等。所以通常只有在有很多元素要处理的情况下，才是值得的，而且需要为每个元素做的工作是非常重要的。在你的情况下，这两个都不是真的。

其次，您正在输出到标准输出。System.out将只允许一个线程同时输出某些内容。这样做是为了在多个线程尝试写入标准输出时，输出不会被过多打乱。这意味着在您的情况下，所有线程基本上都将花费大量时间等待轮到它们编写。

所以，不，您的JVM没有问题。