本文共 3553 字，大约阅读时间需要 11 分钟。

Stream���parallelStream������������

Stream���Java8���������������������������������������������������������������������������������������������������������������������������������������������������������������������������������Iterator���������Stream������������������������������������������������������������������

���.iterator������.stream

���������Iterator������������������������������������������������Stream������������������������������������������������������������������������������������������������������������������������

List
   
     numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9);
numbers.stream()
    .filter(n -> n % 2 == 0) // ���������������
    .map(n -> n * 2)   // ������������������2
    .sorted()          // ���������������
    .findFirst();      // ������������������������������
   

������������������������������������������������������������������������������������

Stream���������������

ForkJoinPool������

���Stream������������������������������ForkJoin������������������������������������������������ForkJoin���������������������������JVM���������������������������������������������������������

-Djava.util.concurrent.ForkJoinPool.common.parallelism=4

ForkJoin���������������������������������������������work-stealing���������������������������������������������������������������������������������������������������������������������������������������������������

ForkJoin������������

parallelStream���������������

parallelStream���������������������������������������������������������������������������������������

public static String query(String q, List
   
     engines) {
    return engines.parallelStream()
        .map(url -> ws.query(q, url))
        .findFirst();
}
   

������������������������������������������������������������������

Stream���parallelStream���������

������������parallelStream������������

• ���������������������������������������������������������������������������
• ������������������������������������������������������������������������������
• ������������������������������������������������������������������

������������parallelStream���������������������������������������������������������������������

������

Stream���parallelStream���Java8������������������������������������������������������������������������������������������ForkJoin���������������������������������������������������������������������������������������������������������������������������������������������������������������������������������