From 82b7d857b9d6bd862fe64b1deea90d3019a1d731 Mon Sep 17 00:00:00 2001 From: javahongxi Date: Sun, 11 Aug 2019 23:46:12 +0800 Subject: [PATCH] ForkJoinTest --- .../java/org/hongxi/java/util/concurrent/ForkJoinTest.java | 6 ++++++ 1 file changed, 6 insertions(+) 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 index 23f414a7..c2497f35 100644 --- 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.ForkJoinPool; 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 class ForkJoinTest { 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 { -- GitLab