Lambada表达式

Lambada的简单使用public class Mytes { //匿名内部类 new Thread(new Runnable() { Override public void run() { System.out.println(内部类线程执行了); } }).start(); //lambda表达式就是将方法体作为参数传递给其他方法 new Thread(()-{ System.out.println(lambda表达式线程执行了); }).start(); } public class Mytes { /* * 使用lambada的前提 * 1.方法有参数 * 2.参数必须是接口 * 3.接口中的方法有且只能用一个 * * */ //定义方法且方法必须有参数 public static void main(String[] args) { //无参数的lambada表达式不能省略 test(()-{System.out.println(无参lambada表达式);}); //有参数类型的lambada表达式可以加表达式的参数类型可以是x,y,z test2((int x)-{System.out.println(有参数的lambada表达式);}); //有参数类型的lambada表达式可以加,可以不写数据类型 test2((x)-{System.out.println(有参数的lambada表达式);}); //有参数类型的lambada表达式可以不加不加也不用写数据类型 test2(x-{System.out.println(有参数的lambada表达式);}); //多个参数的lambada表达式不能省略 test2((x,y)-{System.out.println(有参数的lambada表达式);}); //{ 大括号}只有一个语句可以省略{大括号} test2((x,y)-System.out.println(有参数的lambada表达式)); //{ 大括号}只有多个语句不可以省略{大括号} //有参数类型的lambada表达式可以省略 //有返回值的lambada表达式 test3((x,y)-{ int a0; int b1; return ab; }); //lambada方法体内如果只有一句ruturn可以省略{大括号}和return,直接写值 test3((x,y)-2); //也可以只写一句return但是return后面必须跟值 test3((x,y)- { return 2;}); } public static void test(IA ia){ //调用方法 ia.show(); } //有参数 public static void test2(IB ib){ //调用方法 ib.show(1); } //多个参数 public static void test2(IC ib){ //调用方法 ib.show(1,a); } //返回值参数 public static void test3(ID ib){ //调用方法 ib.show(1,a); } } interface IA{ void show() ; } interface IB{ void show(int a) ; } interface IC{ void show(int a,String b) ; } interface ID{ int show(int a,String b) ; } 实例 public class Mytes { /* * 使用lambada的前提 * 1.方法有参数 * 2.参数必须是接口 * 3.接口中的方法有且只能用一个 * * */ //定义方法且方法必须有参数 public static void main(String[] args) { ExecutorService pool Executors.newFixedThreadPool(3); pool.execute(()-{ for (int i 0; i 10; i) { System.out.println(线程i); } }); pool.shutdown(); //当一个方法的参数是一个接口接口内部只有一个方法那么可以使用lambada表达式 //集合工具Collection ListInteger list new ArrayList(); list.add(5); list.add(1); list.add(3); list.add(2); list.add(4); System.out.println(排序前list); /*Collections.sort(list);//排序list集合 System.out.println(排序后list);*/ //使用lambada表达式 /*Collections.sort(list,(a,b)- {return a-b;});//a-b是升序排序 System.out.println(排序后list); 12345 */ Collections.sort(list,(a,b)- b-a);//b-a是降序排序 System.out.println(排序后list);//54321 } }下面的注解只有一个接口中用一个方法才可以使用同时可以校验是否是函数式接口函数式接口FunctionalInterface函数Supplierimport java.util.function.Supplier; public class Mytes { /* *设计一个方法通过Supplier()方法返回一个长度 * * */ //定义方法且方法必须有参数 public static void main(String[] args) { get(()-{ String sjava; int length s.length(); return length; }); } public static void get(SupplierInteger supplier){ Integer s supplier.get(); System.out.println(s); } }ConsumerFunctionPredicatepublic class Mytes { /* *设计一个方法通过Supplier()方法返回一个长度 * * */ //定义方法且方法必须有参数 public static void main(String[] args) { get(()-{ String sjava; int length s.length(); return length;//返回字符串的长度4 }); get1(x-{ System.out.println(x);//输出字符串java }); get1(x-{ //将字符串转换为大写 String s x.toUpperCase(); System.out.println(s);//输出大写的字符串JAVA }); //传入一个字符串返回一个长度 get2(s-{ return s.length();//返回字符串的长度4 }); //判断是否是一个偶数 get3(x-x%30);//输出true } //Supplier接口 用于获取数据的 public static void get(SupplierInteger supplier){ Integer s supplier.get(); System.out.println(s); } //Consumer接口 用于消费数据的,给你一个数据自己做处理 public static void get1(ConsumerString consumer){ consumer.accept(java); } //FunctionString,Integer 传入一个字符串返回一个整数 public static void get2(FunctionString,Integer function){ Integer n function.apply(java); System.out.println(n); } //PredicateString 传入一个字符串返回一个布尔值 public static void get3(PredicateInteger predicate){ boolean b predicate.test(10); System.out.println(b); } }Stream流public class Demo2 { public static void main(String[] args) { /* * 对stream进行排序 * sorted是排序是一个中间操作 * 中间操作不会执行结果需要调用终止操作才有结果 * foreach是遍历是一个终止操作会有执行结果 * */ StreamInteger stream Stream.of(11, 25, 13, 4,15); //stream.sorted().forEach(x- System.out.println(x)); 升序 stream.sorted((a,b)-b-a) .forEach(x- System.out.println(x));//降序 stream.filter(x-x%20).forEach(x- System.out.println(x));//filter过滤偶数 } } Exception in thread main java.lang.IllegalStateException: stream has already been operated upon or closed at java.base/java.util.stream.AbstractPipeline.init(AbstractPipeline.java:201) at java.base/java.util.stream.ReferencePipeline.init(ReferencePipeline.java:101) at java.base/java.util.stream.ReferencePipeline$StatelessOp.init(ReferencePipeline.java:845) at java.base/java.util.stream.ReferencePipeline$2.init(ReferencePipeline.java:185) at java.base/java.util.stream.ReferencePipeline.filter(ReferencePipeline.java:184) at Demo2.main(Demo2.java:15) stream has already been operated upon or closed报错信息重复使用流因为流只能使用一次。 案例 StreamInteger stream Stream.of(11, 25, 13, 4,15); //过滤排序再输出.结果是4 stream.filter(x-x%20).sorted().forEach(x- System.out.println(x));//filter过滤偶数public class Demo2 { public static void main(String[] args) { /* * R StreamR map(Function? super T, ? extends R mapper); * Function T, R 接收一个参数返回一个结果 * 下面的map里面的参数Function接收的是Integer * */ StreamInteger stream Stream.of(97, 98, 99, 100); stream.map(e-{ int c (int) e; char b(char) c; return b; }).forEach(System.out::println); } }Map获得流Test public void test1(){ MapString, Integer map new HashMap(); map.put(张三丰, 130); map.put(张无忌, 26); map.put(赵敏, 18); map.put(小昭, 28); map.put(刘德华, 50); map.put(小龙女, 18); map.put(周杰伦, 28); map.put(王菲, 28); /* 第一种方式 map是无法直接获得流的需要先转成Set集合 keySet获取所有的key */ // map.keySet().stream().forEach(key - System.out.println(key-map.get(key))); /* 第二种方式 map.entrySet()获取所有的entry对象 每一个entry对象就是Map集合中的每一个键值对儿 */ map.entrySet().stream().forEach(entry - System.out.println(entry.getKey()-entry.getValue())); }补充Collections不可变集合emptyXxx()制造一个空的不可变集合singletonXxx()制造一个只有一个元素的不可变集合unmodifiableXxx()为指定集合制作一个不可变集合以Collections.emptyList()为例看下它的源码:public static final List EMPTY_LIST new EmptyList(); public static final T ListT emptyList() { return (ListT) EMPTY_LIST; }Collect收集数据收集到List集合Test public void test(){ // collect(Collector collector) 收集流中的数据 放到集合中List Set Map ListString list new ArrayList(); Collections.addAll(list,张三丰-男-100,张无忌-男-26,赵敏-女-18,小昭-女-28,刘德华-男-50 ,小龙女-女-18,周杰伦-男-28,王菲-女-28); // list.get(0).s1.split(-); 以-分割返回的是一个数组[张三丰男,100] //把所有的男生都收集起来 // list.stream().filter(s - s.split(-)[1].equals(男)) ListString collect list.stream().filter(s - 男.equals(s.split(-)[1])). //forEach(System.out::println); collect(Collectors.toList());// 把所有的男生都收集起来放到list集合中 System.out.println(collect); }打印结果收集到Set集合Test public void test(){ ListString list new ArrayList(); Collections.addAll(list,张三丰-男-100,张三丰-男-100,张无忌-男-26,赵敏-女-18,小昭-女-28,刘德华-男-50 ,小龙女-女-18,周杰伦-男-28,王菲-女-28); SetString collect list.stream().filter(s - 男.equals(s.split(-)[1])). collect(Collectors.toSet());// 把所有的男生都收集起来放到Set集合中 System.out.println(collect); }收集到List和收集到Set有啥区别List是有序的不去重set是无序的会去重。收集到Map集合里注意map的键不能重复用名字作为Key年龄作为ValueTest public void test(){ ListString list new ArrayList(); Collections.addAll(list,张三丰-男-100,张无忌-男-26,赵敏-女-18,小昭-女-28,刘德华-男-50 ,小龙女-女-18,周杰伦-男-28,王菲-女-28); MapString,Integer collect list.stream().filter(s - 男.equals(s.split(-)[1])). collect(Collectors.toMap(new FunctionString, String() { Override public String apply(String s) { //s是流里面的数据 //拿到 姓名放到map的key中[张三丰-男-100] String s1 s.split(-)[0]; return s1; } }, new FunctionString, Integer() { Override public Integer apply(String s) { //拿到 年龄放到map的value中[张三丰-男-100] String s1 s.split(-)[2]; Integer integer Integer.valueOf(s1); return integer; } }));// 把所有的男生都收集起来放到Set集合中 System.out.println(collect); }结果简化Test public void test(){ ListString list new ArrayList(); Collections.addAll(list,张三丰-男-130,张三丰-男-100,张无忌-男-26,赵敏-女-18,小昭-女-28,刘德华-男-50 ,小龙女-女-18,周杰伦-男-28,王菲-女-28); MapString,Integer collect list.stream().filter(s - 男.equals(s.split(-)[1])). collect(Collectors.toMap( s - s.split(-)[0], s - Integer.parseInt(s.split(-)[2]), (v1, v2) - v1 ));// 把所有的男生都收集起来放到Map集合中 System.out.println(collect); }toMap(Function keyMapper, Function valueMapper, BinaryOperator mergeFunction)第一个参数keyMapper指定Map 的 key这里是人名s.split(-)[0]第二个参数valueMapper指定Map 的 value这里是年龄转成 int第三个参数mergeFunction键冲突时的合并策略也就是当出现相同 key时怎么处理新旧两个 valu(v1, v2) - v1的含义v1已经存入 Map 里的旧 valuev2新流中遇到重复 key 时的新 value- v1发生 key 重复时保留旧值 v1舍弃新值 v2如上图所示有两个张三丰键重复会报错可是使用第三个参数会保留130岁的张三丰舍弃100岁的张三丰。