Java8 Stream

描述：Java8 开始，Collection集合中新增了两个和流有关的方法，分别Stream同步流和parallelStream异步流，通过lambda表达对集合实现高效的处理

• 自定义相关流的操作

// 从0开始，依次递增2进行遍历，保留前2位后进行截流并输出
Stream intStream = Stream.iterate(0, x -> x + 2);
intStream.limit(2).forEach(item -> { System.out.println(item); });

// 生成布尔流，保留前2位后进行截流并输出
Stream booleanStream = Stream.generate(() -> new Random().nextBoolean());
booleanStream.limit(2).forEach(item -> { System.out.println(item); });

// 生成整型流，保留前2位后进行截流并输出
Stream integerStream = Stream.generate(() -> new Random().nextInt(10));
integerStream.limit(2).forEach(item -> { System.out.println(item); });

// 生成Double流，保留前2位后进行截流并输出
Stream doubleStream = Stream.generate(() -> new Random().nextDouble());
doubleStream.limit(2).forEach(System.out::println);

Stream integerStream = Arrays.stream(new Integer[]{1, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10});
integerStream
        .distinct() // 去重
        .sorted((o1, o2) -> o2 - o1) // 排序
        .filter(item -> item % 2 == 0) // 过滤
        .map(item -> item += 1) // 数据操作
        .forEach(.forEach(item -> System.out.println(item)); // 遍历
// 将数组转发成列表
List integerList = integerStream.collect(Collectors.toList());

• 并行流

List studentList = new ArrayList<>();
studentList.add(new Student("张三", 20));
studentList.add(new Student("李四", 22));
studentList.add(new Student("王五", 24));
studentList.add(new Student("赵六", 26));
studentList.parallelStream().distinct().forEach(item -> {
System.out.println(MessageFormat.format("当前线程名称：{0}，待处理用户数据：{1}", Thread.currentThread().getName(), item.getName()));
        });

• 返回结果
  当前线程名称：ForkJoinPool.commonPool-worker-2，待处理用户数据：王五
  当前线程名称：ForkJoinPool.commonPool-worker-4，待处理用户数据：张三
  当前线程名称：ForkJoinPool.commonPool-worker-9，待处理用户数据：李四
  当前线程名称：ForkJoinPool.commonPool-worker-11，待处理用户数据：赵六