Stream(流)是一个来自数据源的元素队列并支持聚合操作
和以前的Collection操作不同, Stream操作还有两个基础的特征:
public static void main(String[] args) { ArrayList<String> arrayList=new ArrayList<String>(); arrayList.add("小王,98"); arrayList.add("小李,95"); arrayList.add("小陈,87"); arrayList.stream().map(s->s.split(",")[1]) .map(Integer::parseInt) .filter(n -> n > 90) .forEach(System.out::println); }
stream() − 为集合创建串行流。
parallelStream() − 为集合创建并行流。
串行流
1 public static void main(String[] args) { 2 //生成流,并筛选出不是空字符串的集合 3 List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl"); 4 List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList()); 5 for (int i = 0; i < filtered.size(); i++) { 6 System.out.println(filtered.get(i)); 7 } 8 }
并行流
1 public static void main(String[] args) { 2 List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); 3 // 获取空字符串的数量 4 long count = strings.parallelStream().filter(string -> string.isEmpty()).count(); 5 System.out.println(count); 6 }
1 public static void main(String[] args) { 2 //使用forEach遍历打印集合中的数字 3 ArrayList<Integer> arrayList=new ArrayList<Integer>(); 4 arrayList.add(1); 5 arrayList.add(2); 6 arrayList.add(3); 7 arrayList.add(4); 8 arrayList.add(5); 9 arrayList.add(6); 10 arrayList.stream().forEach(System.out::println); 11 }
1 public static void main(String[] args) { 2 //使用map输出元素对应的平方 3 List<Integer> numbers = Arrays.asList(1,2,3,4,5,6); 4 numbers.stream().map(i->i*i).forEach(System.out::println); 5 }
1 public static void main(String[] args) { 2 //使用 filter 方法过滤空字符串的个数 3 List<String>strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl"); 4 long count = strings.stream().filter(string -> string.isEmpty()).count(); 5 System.out.println(count); 6 }
1 public static void main(String[] args) { 2 //使用 limit 方法打印出 3 条数据: 3 ArrayList<Integer> arrayList = new ArrayList<Integer>(); 4 arrayList.add(1); 5 arrayList.add(2); 6 arrayList.add(3); 7 arrayList.add(4); 8 arrayList.add(5); 9 arrayList.add(6); 10 arrayList.stream().limit(3).forEach(System.out::println); 11 }
1 public static void main(String[] args) { 2 //使用 sorted 方法集合中的元素排序: 3 ArrayList<Integer> arrayList = new ArrayList<Integer>(); 4 arrayList.add(1); 5 arrayList.add(22); 6 arrayList.add(13); 7 arrayList.add(45); 8 arrayList.add(50); 9 arrayList.add(6); 10 arrayList.stream().sorted().forEach(System.out::println); 11 }
1 public static void main(String[] args) { 2 List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd", "", "jkl"); 3 List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList()); 4 5 System.out.println("筛选列表: " + filtered); 6 String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", ")); 7 System.out.println("合并字符串: " + mergedString); 8 }
1 public static void main(String[] args) { 2 List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5); 3 4 IntSummaryStatistics stats = numbers.stream().mapToInt((x) -> x).summaryStatistics(); 5 6 System.out.println("列表中最大的数 : " + stats.getMax()); 7 System.out.println("列表中最小的数 : " + stats.getMin()); 8 System.out.println("所有数之和 : " + stats.getSum()); 9 System.out.println("平均数 : " + stats.getAverage()); 10 }