Java Stream的基本概念以及创建方法

Random random = new Random(29);
random.ints()
   .filter(v -> v > 5 && v < 31)
   .limit(3)
   .forEach(System.out::println);

// output:
//  21
//  22
//  28

IntStream stream = new Random(29).ints();
stream.filter(v -> v > 5 && v < 31)
   .limit(3)
   .forEach(System.out::println);
// 当执行了终端操作后再使用，就会出现一下异常提示信息
// java.lang.IllegalStateException: stream has already been operated upon or closed
stream.forEach(System.out::println);

List<Integer> list = new ArrayList<>(Arrays.asList(1, 2, 3, 4, 5));
// 创建一个普通的流
Stream<Integer> stream = list.stream();
// 创建一个并行流
Stream<Integer> parallelStream = list.parallelStream();

IntStream stream = Arrays.stream(new int[]{1, 2, 3});
// 生成流对应的并行流
IntStream parallelStream = stream.parallel();

// 产生一个不包含任何元素的流
Stream<Object> stream1 = Stream.empty();

// 由给定元素所生成的流
Stream<Integer> stream2 = Stream.of(1, 2, 3);

// 合并两个流产生一个新的流
Stream<Object> stream3 = Stream.concat(stream1, stream2);

// 创建一个<无限流>，流中的数据是通过调用所传函数产生的
Stream<Double> stream4 = Stream.generate(Math::random);

// 创建一个<无限流>，流中的数据由第一个参数、将
// 第一个参数作为函数参数调用产生的值以及不断将
// 函数调用得到的值作为参数继续调用所组成，
// 例如下面会生成1,2,3....的整数流
Stream<Integer> stream5 = Stream.iterate(1, v -> v + 1);

// 创建范围为[1, 5)组成的整数流
IntStream stream6 = IntStream.range(1, 5);

// 创建范围为[1, 5]组成的整数流
IntStream stream7 = IntStream.rangeClosed(1, 5);

// 通过流的建造者模式创建流
Stream.Builder<Integer> builder = Stream.builder();
for (int i = 0; i < 10; i++) {
  // add 与 accept 方法均可将元素添加到流中
  // 区别是 add 无返回值, accept 会返回当前 builder 的 this 对象
  // 底层 add 方法也是调用了 accept 然后返回 this
  // 因此对于 add 方法可以进行链式调用
  builder.add(i);
  builder.accept(i);
}
Stream<Integer> stream8 = builder.build();

try {
  String dir = System.getProperty("user.dir");
  // 以下两种方法均是获取文件中行数据组成的流
  Stream<String> stream1 = new BufferedReader(new FileReader(dir + "\\demo.txt")).lines();
  Stream<String> stream2 = Files.lines(Paths.get(dir + "\\demo.txt"));
  // 获取指定路径下所有文件/文件夹的路径组成的流
  Stream<Path> stream3 = Files.list(Paths.get("d:\\temp"));
  // 获取指定路径下以及指定最深文件层级内(在这里为2)且满足函数条件的所有文件/文件夹的路径组成的流
  Stream<Path> stream4 = Files.find(
    Paths.get("d:\\temp"), 1, (path, basicFileAttributes) -> path.isAbsolute());
  // 获取指定路径下以及指定最深文件层级内(在这里为2)所有文件/文件夹的路径组成的流
  Stream<Path> stream5 = Files.walk(Paths.get("d:\\temp"), 2);
} catch (IOException e) {
  e.printStackTrace();
}

Random random = new Random();
// 以下三种方式得到的均是随机数组成的<无限流>
IntStream stream1 = random.ints();
DoubleStream stream2 = random.doubles();
LongStream stream3 = random.longs();
Stream<Integer> boxedStream = stream1.boxed();

// 对数组元素进行倒序排序
// 如果不进行装箱(boxed)处理，则只能使用默认的升序排序方法
// 通过装箱，则可以通过自定义比较器，实现更加多样的排序
int[] arr = {1, 5, 4, 6, 3, 9, 4, 5, 6, 4};
int[] reverseArr = Arrays.stream(arr)
             .boxed()
             .sorted(Comparator.reverseOrder())
             .mapToInt(Integer::valueOf)
             .toArray();
// output: [9, 6, 6, 5, 5, 4, 4, 4, 3, 1]
System.out.println(Arrays.toString(reverseArr));

String s = "1,2,3,4,5,6,7";
// 由分割后的字符串组成的流
// 在这里就是"1", "2", "3", "4", "5", "6", "7"组成的流
Stream<String> stream1 = Pattern.compile(",").splitAsStream(s);
BitSet bitSet = new BitSet();
for (int i = 0; i < 10; i++) {
  if (i % 2 == 0) {
    bitSet.set(i);
  }
}
// 由 bitset 中被设置为 true 的位下标所组成的流
// 在这里就是0, 2, 4, 6, 8
IntStream stream2 = bitSet.stream();
try {
  String dir = System.getProperty("user.dir");
  JarFile jarFile = new JarFile(dir + "\\demo.jar");
  // 由指定 jar 包中所有文件及文件夹的 JarEntry 对象所组形成的流
  Stream<JarEntry> stream3 = jarFile.stream();
} catch (IOException e) {
  e.printStackTrace();
}