Stream

热门实例: https://www.w3cschool.cn/java/codetag-stream-lambda.html

问题验证

两个并行流之间的执行顺序

如果一段程序中有两个并行流, 会执行完第一个并行流, 再去执行第二个并行流

public class MyStream {
    public static void main(String[] args) {
        // 测试多个并行流的执行顺序
        IntStream.range(0, 1000)
                //转换成并行流
                .parallel()
                .forEach(x -> System.out.println("AAAAAAAAAAAAA: " + x + ": " + Thread.currentThread().getName()));
        System.out.println("======================== new Stream ========================");
        IntStream.range(0, 1000)
                //转换成并行流
                .parallel()
                .forEach(x -> System.out.println("BBBBBBBBBBBB: " + x + ": " + Thread.currentThread().getName()));


    }
}

Stream按照指定尺寸分割集合

• 应用案例: oracle IN 查询 每次查询大小不能大于1000

queryWrapper.and(qw -> {
    int group = (int) Math.ceil((double) fieldValueList.size() / MAX_IN_SIZE);
    Stream.iterate(0, index -> index + MAX_IN_SIZE).limit(group).forEach(index ->
        qw.or(subQw -> subQw.in(sqlName, fieldValueList.stream().skip(index).limit(MAX_IN_SIZE).collect(Collectors.toList()))));
});