Add samples

winterbe · winterbe · commit 0aac70031d7a · 2014-07-28T17:41:12.000+02:00
diff --git a/src/com/winterbe/java8/Streams12.java b/src/com/winterbe/java8/Streams12.java
@@ -1,7 +1,11 @@
 package com.winterbe.java8;
 
+import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.List;
+import java.util.UUID;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.TimeUnit;
 
 /**
  * @author Benjamin Winterberg
@@ -11,9 +15,36 @@ public class Streams12 {
     public static void main(String[] args) {
         List<String> strings = Arrays.asList("a1", "a2", "b1", "c2", "c1");
 
-//        test1(strings);
+//        test1();
 //        test2(strings);
         test3(strings);
+//        test4();
+    }
+
+    private static void test4() {
+        List<String> values = new ArrayList<>(100);
+        for (int i = 0; i < 100; i++) {
+            UUID uuid = UUID.randomUUID();
+            values.add(uuid.toString());
+        }
+
+        // sequential
+
+        long t0 = System.nanoTime();
+
+        long count = values
+            .parallelStream()
+            .sorted((s1, s2) -> {
+                System.out.format("sort:    %s <> %s [%s]\n", s1, s2, Thread.currentThread().getName());
+                return s1.compareTo(s2);
+            })
+            .count();
+        System.out.println(count);
+
+        long t1 = System.nanoTime();
+
+        long millis = TimeUnit.NANOSECONDS.toMillis(t1 - t0);
+        System.out.println(String.format("parallel sort took: %d ms", millis));
     }
 
     private static void test3(List<String> strings) {
@@ -51,7 +82,7 @@ private static void test2(List<String> strings) {
     private static void test1() {
         // -Djava.util.concurrent.ForkJoinPool.common.parallelism=5
 
-//        ForkJoinPool commonPool = ForkJoinPool.commonPool();
-//        System.out.println(commonPool.getParallelism());
+        ForkJoinPool commonPool = ForkJoinPool.commonPool();
+        System.out.println(commonPool.getParallelism());
     }
 }
