Skip to content

Commit bbae248

Browse files
committed
简单修改,增加注释
1 parent ae8122f commit bbae248

3 files changed

Lines changed: 4 additions & 2 deletions

File tree

.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,3 +11,5 @@
1111

1212
# Repository wide ignore mac DS_Store files
1313
.DS_Store
14+
*.lck
15+
*.log

src/main/java/lambdasinaction/chap7/ParallelStreams.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ public static long sequentialSum(long n) {
1717
}
1818

1919
public static long parallelSum(long n) {
20-
return Stream.iterate(1L, i -> i + 1).limit(n).parallel().reduce(Long::sum).get();
20+
return Stream.iterate(1L, i -> i + 1).limit(n).parallel().reduce(Long::sum).get();//并行处理流
2121
}
2222

2323
public static long rangedSum(long n) {

src/main/java/lambdasinaction/chap7/ParallelStreamsHarness.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
public class ParallelStreamsHarness {
77

88
public static final ForkJoinPool FORK_JOIN_POOL = new ForkJoinPool();
9-
9+
//测试并行的时间
1010
public static void main(String[] args) {
1111
System.out.println("Iterative Sum done in: " + measurePerf(ParallelStreams::iterativeSum, 10_000_000L) + " msecs");
1212
System.out.println("Sequential Sum done in: " + measurePerf(ParallelStreams::sequentialSum, 10_000_000L) + " msecs");

0 commit comments

Comments
 (0)