Stream

news2025/1/13 10:21:18

一函数式接口

1 特点

2 核心函数式接口

1） Consumer

2） Supplier

3） Function

4） Predicate

5）扩展：BiFunction

二 Stream

1 stream操作过程

1）中间操作

2）终端操作

2 创建Stream对象

1）通过集合获得Stream对象

2）其他

3 终端操作

forEach()

count() , max() , min()

collect()

4 中间操作

filter()

map()

sorted()

limit() & skip()

一函数式接口

1 特点

接口中有且仅有一个抽方法
可以使用lambda表达式
可以使用@FunctionalInterface声明接口
在函数式接口中，可以定义多个默认的非抽象方法

2 核心函数式接口

jdk中给我们提供了一些常用的函数式接口

jdk1.8以前，就存在函数式特点接口： Compartor ，Comparable

jdk1.8以后，提供了一些常用的函数式接口，其中有4个核心接口

1） Consumer

消费型接口，传递参数，使用参数做一个处理。没有返回值 void accept(T t);

Consumer<String> mc = (String s1)->{
    System.out.println(s1.length());
};
mc.accept(s);
//-------------------------------------------
Consumer<String> mc1 = (String s1)->{
    System.out.println(s1.length());
};
Consumer<String> mc2 = (String s1)->{
    System.out.println(s1.toUpperCase());
};
Consumer<String> mc3 = s1->{
    System.out.println(s1.substring(0,5));
};
//mc2.accept(s);

//这是一个链式操作，先实现消费功能mc3，再实现消费功能mc2,最后实现消费功能mc1
mc3.andThen(mc2.andThen(mc1)).accept(s);

2） Supplier

供给型接口，无需要传递参数，返回对象 T get();

//需要产生一个随机数
//创建了一个对象 Object obj = new Object()
Supplier<Integer> s1 = ()->{
    Random r = new Random();
    return r.nextInt(10);
};
Integer num = s1.get() ;

3） Function

功能型接口，需要传递参数，根据参数做处理，将处理结果返回 R apply(T t); Function<T,R>

String s = "dmc is good" ;
//需要实现功能，将字符串转换成大小
Function<String,String> f1 = (String s1)->{
    return s1.toUpperCase();
};
System.out.println( f1.apply(s) );
//---------------------------------------------
String s = "dmc is good" ;
//需要实现功能，将字符串转换成大小
Function<String,String> f1 = (String s1)->{
    System.out.println("1操作");
    return s1.toUpperCase();
};
//System.out.println( f1.apply(s) );

Function<String,String> f2 = s1->{
    System.out.println("2操作");
    return s1.substring(0,3);
};

//f1处理后，再进行一次f2的处理
//System.out.println( f1.andThen(f2).apply(s) );
//f1处理前，先进行一次f2的处理
System.out.println( f1.compose(f2).apply(s) );

4） Predicate

断言型接口，传递参数，根据参数做判断，返回boolean boolean test(T t)

//判断user登录信息是否正确
Predicate<User> p1 = (User user1)->{
    return user1.uname.equals("dmc") && user1.upass.equals("123");
};
System.out.println(p1.test(user)?"登录成功":"登录失败");
//----------------------------------------------
User user = new User("dmc","1234") ;
//判断user登录信息是否正确
Predicate<User> p1 = (User user1)->{
    return user1.uname.equals("dmc") ;
};
Predicate<User> p2 = (User user1)->{
    return user1.upass.equals("123") ;
};

//函数式接口中的链式功能，基于的是一个对象
System.out.println(p1.or(p2).test(user)?"登录成功":"登录失败");
System.out.println(p1.negate().test(user));

5）扩展：BiFunction

R apply(T t,U u); BiFunction<T,U,R>

Num num = new Num(10,20);
Function<Num,Integer> f1 = (num1)->num.x + num.y ;
//------------------------------------------
//二元操作功能
BiFunction<Integer,Integer,Integer> b1 = (x , y)-> x+y ;
System.out.println(b1.apply(10,20));

二 Stream

1 stream操作过程

stream操作分为2部分

如果没有终端操作，中间操作无法验证结果。

只有终端操作执行时，中间操作才开始执行。（在终端操作执行前，中间操作只是一个标记）

1）中间操作

中间操作本身不会执行，只是一个标记，会在终端操作执行时才执行。

中间操作语法会返回一个Stream对象，可以以链式的方式增加多个中间操作(标记)

2）终端操作

要么返回一个具体的数据，要么就执行遍历操作，什么都不返回(void)

整个流操作在执行终端操作方法时就结束了(如果有后续操作，也不是流操作，或者是一个新的流操作)