| 注册
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
jopen
9年前发布

Java8 stream 学习1

原文  http://renchx.com/java8-stream/
 

java8 当中引入的了流处理。引入流处理方便对集合进行处理,当我们想要遍历集合进行处理的时候可以使用 stram api 进行操作。

一个简单的例子:统计一个字符串集合当中长度大于12的字符串的个数。

List<String> words;//从某处获取  int count = 0;  for(String w : words) {      if(w.length() > 12) {          count++;      }  }

如果使用 stram api 进行处理如下,简洁明了:
List<String> words;//从某处获取  int count = words.stream().filter( w -> w.length() > 12).count();

stream 与集合的区别:

  1. stream 自己不会存储元素
  2. stream 不会改变原集合
  3. stream 可能是延迟执行的

处理 stream 也可以并行,只需要方法修改成 words.parallelStream().filter( w -> w.length() > 12).count()

当我们使用 stream 的时候一般会有三个阶段来建立一个操作流水线。

  1. 创建 stream
  2. 在一个或者多个步骤当中,指定当初的 stream 转换成另外一个 stream 的中间操作
  3. 使用终止操作产生一个结果,该操作会强制延迟操作立即执行,并且这个 stream 就不可以继续使用。

创建 stream

创建 stream 如下:

@Test      public void createStream() {          Stream<String> stream = Stream.of("a", "b");          Stream<String> stream2 = Stream.empty();          Stream<String> stream3 = Stream.generate(() -> "aaa");// generate方法生产一个无限的Stream          Stream<Double> stream4 = Stream.generate(Math::random);          Stream<BigInteger> stream5 = Stream.iterate(BigInteger.ZERO, n -> n.add(BigInteger.ONE));// iterate方法生产一个无限的Stream      }

Stream.iterate 方法的第一个参数是一个种子,第二个参数是一个函数。所以 stream5 序列的第一个元素是 BigInteger.ZERO,第二个是相当于 f(BigInteger.ZERO) ,我们传递的函数就是add BigInteger.ONE,第三个元素是f(f(BigInteger.ONE));

stream 转换

@Test      public void streamTOstream() {          Stream<String> stream = Stream.of("a", "b", "c", "da", "asdass");          Stream<String> stream2 = stream.filter(n -> n.length() > 3);          Stream<String> stream3 = stream.map(String::toUpperCase);// map方法是对每个元素操作传入的函数          Stream<Stream<Character>> stream4 = stream.map(w -> characterStream(w));          //上面的结果是[['a'],['b'],['c'],['d','a'],['a','s' ...]]          //如果我们想获得所有单词的字符 Stream<Character> 这个可以使用 flatMap 方法          Stream<Character> stream5 =  stream.flatMap(w -> characterStream(w));          //上面的结果是['a', 'b', 'c', 'd', 'd', ...]      }        public static Stream<Character> characterStream(String string) {          List<Character> result = new ArrayList<Character>();          for (char c : string.toCharArray()) {              result.add(c);          }          return result.stream();      }

提取子流和组合流和就状态转换

@Test      public void streamTOstream2() {          Stream<Double> stream1 = Stream.generate(Math::random).limit(100);          Stream<Double> stream2 = Stream.generate(Math::random).limit(100);          Stream<Double> stream3 = Stream.concat(stream1, stream2);          Stream<String> stream = Stream.of("a", "b", "c", "da", "asdass", "b");          Stream<String> streamA = stream.distinct();//去重          Stream<String> streamB = stream.sorted(Comparator.comparing(String::length));//排序        }

【参考资料】

  1. 写给大忙人看的Java SE 8

 本文由用户 jopen 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
 转载本站原创文章,请注明出处,并保留原始链接、图片水印。
 本站是一个以用户分享为主的开源技术平台,欢迎各类分享!
 本文地址:https://www.open-open.com/lib/view/open1449664958098.html
Java8 Java开发