Stream

  • 流不存储元素；它们存储在底层的集合或者按需生成；
  • 流操作不改变它们的源数据；例如filter方法不会从一个新流中删除元素，而是生成一个不包含特定元素的新流；
  • Stream操作可能是延迟执行的；
  • 和迭代器类似，流只能遍历一次
  • filter和map等操作是无状态的，它们并不存储任何状态。reduce等操作要存储状态才能计算出一个值。sorted和distinct等操作也要存储状态，因为它们需要把流中的所有元素缓存起来才能返回一个新的流。这种操作称为有状态操作

支持两种类型操作：

  • 中间操作（如filter或map）
  • 终端操作（如count、findFirst、forEach和reduce）

常用API

  • IntStream.rangeClosed(1, 100)：rangeClosed方法来生成1到100之间的所有数字
  • Stream.of：显式值创建一个流
  • Stream.empty()：创建一个空流
  • Arrays.stream(numbers)：从数组创建一个流

外部迭代与内部迭代

使用Collection接口需要用户去做迭代（比如用for-each），这称为外部迭代

Streams库使用内部迭代——它帮你把迭代做了，还把得到的流值存在了某个地方，你只要给出一个函数说要干什么就可以了

API

Stream操作 描述
filter filter转换生成一个匹配一定条件的新流过滤
mapToXXX 使用toXXXFunction对流中的元素执行一对一的转换，该方法返回的新流中包含了toXXXFunction转换生成的所有元素；
forEach 迭代
count 统计
map 将流中的值进行某种转换
reduce 归约操作
generate 接受一个无参数的函数
iterate iterate方法接受一个"种子"值和一个函数并对之前的值重复应用该函数
limit 返回一个包含n个元素的新流
skip 跳过或丢弃前n个元素
toArray 返回一个数组
collect 收集
concat 连接两个流
distinct 过滤重复元素
sorted 排序
peek 每当检索元素的时候就会调用一次(可用来调试流)
max 取最大值
min 取最小值
findFirst 返回非空集合中的第一个值
findAny 返回任何一个匹配的元素
anyMatch 返回是否含有匹配元素
flatMap flatmap方法让你把一个流中的每个值都换成另一个流，然后把所有的流连接起来成为一个流

Method

Stream<String> stream = Stream.of("1,2,3,4,10".split(","));
Arrays.stream("h,2,34,3".split(",")).forEach(System.err::println);

// Stream<Double> stm = Stream.generate(Math::random).limit(10); // 如果没有limit流会一直运行
Stream<String> stm = Stream.generate(() -> "hello").limit(10);

Pattern.compile("\\PL+").splitAsStream("hello,world").forEach(System.err::println);

CodeList

Runnable run = () -> System.out.println("running...”); ##不带参数
ActionListener action = event -> System.err.println("button click”); ##带参数
Runnable run = () -> { ##代码块
System.out.println("running...");
System.err.println("end");
return;
};
IntSummaryStatistics summaryStatistics = list.stream().mapToInt(e -> e.intValue()).summaryStatistics(); //统计
方法引用：System.out::println(语法：Classname::method)

常见用法

// 打印输出
list.stream().forEach(System.err::println);

// 过滤
list.stream().filter(t -> t > 50).forEach(System.out::println);

// 排序
list.stream().sorted((x1, x2) -> x2.compareTo(x1)).forEach(System.err::println);

// 求总记录数
System.err.println(list.stream().count());

// 转换为Map
Map<String, TerraOrderBill> billMap = orderBillList.stream().collect(
    Collectors.toMap(TerraOrderBill::getBillId,bill -> bill));

// 求和
double totalAmount = seEntries.stream().mapToDouble(t -> t.getRealPayAmount()).sum();

// distinct
recordEntrys.stream().filter(t -> !StringUtils.isEmpty(t.getSupplierId()))
    .map(SettlementRecordEntry::getSupplierId).distinct().collect(Collectors.toList());

// 并行处理
sum = list.parallelStream().mapToInt(t -> t.intValue()).sum();

results matching ""

    No results matching ""