ForkJoinTest

javahongxi · Aug 11, 2019 · 82b7d85 · 82b7d85
1 parent f7d9449
commit 82b7d85
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ForkJoinTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ForkJoinTest.java
@@ -6,6 +6,7 @@
 import java.util.concurrent.RecursiveTask;
 import java.util.concurrent.RecursiveAction;
 import java.util.concurrent.CountedCompleter;
+import java.util.stream.IntStream;
 
 /**
  * @author shenhongxi 2019/8/11
@@ -33,6 +34,11 @@ public static void main(String[] args) {
         for (int i = 0; i < 10; i++) {
             System.out.print(array[i] + " ");
         }
+
+        System.out.println();
+        IntStream.range(1, 10).forEach(e -> System.out.print(e + " "));
+        System.out.println();
+        IntStream.range(1, 10).parallel().forEach(e -> System.out.print(e + " "));
     }
 
     static class AccumulationTask extends RecursiveTask<Integer> {