改变测试方法

vw2019 · vw2019 · commit cfce5b70e074 · 2018-10-18T15:18:38.000+08:00
diff --git a/src/main/java/lambdasinaction/chap11/BestPriceFinderMain.java b/src/main/java/lambdasinaction/chap11/BestPriceFinderMain.java
@@ -9,8 +9,8 @@ public class BestPriceFinderMain {
 
     public static void main(String[] args) {
 //        execute("sequential", () -> bestPriceFinder.findPricesSequential("myPhone27S"));
-//        execute("parallel", () -> bestPriceFinder.findPricesParallel("myPhone27S"));
-//        execute("composed CompletableFuture", () -> bestPriceFinder.findPricesFuture("myPhone27S"));
+        execute("parallel", () -> bestPriceFinder.findPricesParallel("myPhone27S"));
+        execute("composed CompletableFuture", () -> bestPriceFinder.findPricesFuture("myPhone27S"));
         bestPriceFinder.printPricesStream("myPhone27S");
     }
 
diff --git a/src/main/java/lambdasinaction/chap4/StreamParallellTest.java b/src/main/java/lambdasinaction/chap4/StreamParallellTest.java
@@ -3,27 +3,28 @@
 import org.apache.commons.collections4.ListUtils;
 
 import java.util.List;
+import java.util.function.Supplier;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
 /**
  * @author vector
  * @date: 2018/10/18 0018 10:00
- *
+ * <p>
  * List<List<?>> -> List<?>
- *
+ * <p>
  * 使用parallelstream需注意【共享对象的可变状态】
  * 如使用foreach就能改变其状态
  * 需要特别注意下
  */
 public class StreamParallellTest {
 
-    public static List<String> sum(List<Integer> items,int count) {
+    public static List<String> sum(List<Integer> items, int count) {
         List<List<Integer>> listList = ListUtils.partition(items, count);
         return listList.stream().flatMap(List::stream).map(StreamParallellTest::delayFun).collect(Collectors.toList());
     }
 
-    public static List<String> parallelSum(List<Integer> items,int count) {
+    public static List<String> parallelSum(List<Integer> items, int count) {
         List<List<Integer>> listList = ListUtils.partition(items, count);
         return listList.parallelStream().flatMap(List::stream).map(StreamParallellTest::delayFun).collect(Collectors.toList());
     }
@@ -37,26 +38,20 @@ public static String delayFun(int digist) {
         return digist + "";
     }
 
+    private static void execute(String msg, Supplier<List<String>> supplier) {
+        long s = System.nanoTime();
+        supplier.get();
+        long e = System.nanoTime();
+        long duration = (e - s) / 1_000_000;
+
+        System.out.println(msg + " done in " + duration + " msecs");
+    }
+
+
     public static void main(String[] args) {
         List<Integer> items = IntStream.rangeClosed(1, 50).boxed().collect(Collectors.toList());
         System.out.println(items);
-        long s = System.currentTimeMillis();
-        sum(items,10);
-        long e = System.currentTimeMillis();
-        System.out.println((double)(e-s)/1_000 + "s");
-
-        long s1 = System.currentTimeMillis();
-        parallelSum(items,10);
-        long e1 = System.currentTimeMillis();
-        System.out.println((double)(e1-s1)/1_000 + "s");
-//        for (int i = 0; i < 10; i++) {
-//            for (int j = 0; j < 10; j++) {
-//                long s1 = System.currentTimeMillis();
-//                parallelSum(items,10);
-//                long e1 = System.currentTimeMillis();
-//                System.out.println((double)(e1-s1)/1_000 + "s");
-//            }
-//            System.out.println("============================");
-//        }
+        execute("sum", () -> sum(items, 10));
+        execute("parallelSum", () -> parallelSum(items, 10));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -9,8 +9,8 @@ public class BestPriceFinderMain {`
`9`	`9`
`10`	`10`	`public static void main(String[] args) {`
`11`	`11`	`// execute("sequential", () -> bestPriceFinder.findPricesSequential("myPhone27S"));`
`12`		`-// execute("parallel", () -> bestPriceFinder.findPricesParallel("myPhone27S"));`
`13`		`-// execute("composed CompletableFuture", () -> bestPriceFinder.findPricesFuture("myPhone27S"));`
	`12`	`+ execute("parallel", () -> bestPriceFinder.findPricesParallel("myPhone27S"));`
	`13`	`+ execute("composed CompletableFuture", () -> bestPriceFinder.findPricesFuture("myPhone27S"));`
`14`	`14`	`bestPriceFinder.printPricesStream("myPhone27S");`
`15`	`15`	`}`
`16`	`16`