java8新特性之数据流(串行流和并行流)

2024-04-10 15:18

本文主要是介绍java8新特性之数据流(串行流和并行流),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.什么是数据流(what)

  • java.util.Stream表示了某一种元素的序列,在这些元素上可以进行各种操作。

2.解决什么问题(why)

  • Stream操作可以是中间操作,也可以是完结操作。完结操作会返回一个某种类型的
    值,而中间操作会返回流对象本身,并且你可以通过多次调用同一个流操作方法来 将操作结果串起来!

3.怎么用(waht do)

3.1 语法

注:

  • 中间操作:返回的结果是还是Stream流,允许在其返回结果上继续进行流的操作
  • 中止操作:不返回流,所以我们不能再调用其他的流操作
    所有的demo都会在3.2
    (大家生理
    1. Filter(中间操作)
    接受一个Boolean类型的变量,并将所有流对象中的元素进行过滤
    3. Sorted
    Sorted是一个中间操作,能够返回一个排过序的流对象的视图。可指定排序规则!默认正序,逆序:orted(Comparator.reverseOrder())(注意:他的排序是按照ASCII码值排序)
    4. Map
    map是一个对于流对象的中间操作,通过给定的方法,它能够把流对象中的每一个 元素对应到另外一个对象上 。
    5. Match
    所有的匹配操作都是终结操作。匹配操作有多种不同的类型,都是用来判断某一种规则是否与流对象相互吻合的。只返回一个boolean类型的结果。有anyMatch、allMatch、noneMatch。
    6. Count
    Count是一个终结操作,它的作用是返回一个数值,用来标识当前流对象中包含的 元素数量。
    7. Reduce
    Reduce操作是一个终结操作,它能够通过某一个方法,对元素进行削减操作。该操作的 结果会放在一个Optional变量里返回。
    8. ForEach
    ForEach是一个中止操作。ForEach接受一个function接口类型的变量,用来执行对每一个元素 的操作。。它不返回流,所以我们不能再调用其他的流操作。

3.2 示例

//通过串行流实现过滤判断。List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abed", "", "jkl");//Tips limit获取指定数量的流List<String> filtered = strings.stream().limit(3).filter(string -> !string.isEmpty()).collect(Collectors.toList());filtered.forEach(System.out::println);System.out.println("====================");//通过并行流实现迭代List<String> parallelString = strings.parallelStream().filter(s -> !s.isEmpty()).collect(Collectors.toList());parallelString.forEach(System.out::println);//forEach来迭代流中的每个数据System.out.println("forEach来迭代流中的每个数据");parallelString.forEach(s->{s="er";System.out.println(s);});//map 方法用于映射每个元素到对应的结果,也可以用于迭代流中的元素List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);//Tips: distinct:去重作用List<Integer> squaresList = numbers.stream().map(i -> i * i).distinct().collect(Collectors.toList());squaresList.forEach(System.out::println);List<String> stringList = parallelString.stream().map(s -> s + s).distinct().collect(Collectors.toList());stringList.forEach(System.out::println);//filter 方法用于通过设置的条件过滤出元素。以下代码片段使用 filter 方法过滤出空字符串:List<String> filterString = Arrays.asList("abc", "", "bc", "efg", "abed", "", "jkl");// 获取空字符串的数量long count = filterString.stream().filter(String::isEmpty).count();List<String> filterCollect = filterString.stream().filter(String::isEmpty).collect(Collectors.toList());System.out.println(count);System.out.println(filterCollect.size());//sorted 方法用于对流进行排序。以下代码片段使用 sorted 方法对输出的 10 个随机数进行排序!Random random = new Random();random.ints().limit(10).sorted().forEach(System.out::println);//Collectors 类实现了很多归约操作,例如将流转换成集合和聚合元素。Collectors 可用于返回列表或字符串List<String> collectList = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());System.out.println("筛选列表: " + collectList);String mergedString = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(""));System.out.println("合并字符串: " + mergedString);List<Integer> integerList = Arrays.asList(3, 2, 2, 3, 7, 3, 5);//一些产生统计结果的收集器也非常有用。它们主要用于int、double、long等基本类型上,它们可以用来产生类似如下的统计结果。IntSummaryStatistics stats = integerList.stream().mapToInt((x) -> x).summaryStatistics();System.out.println("列表中最大的数 : " + stats.getMax());System.out.println("列表中最小的数 : " + stats.getMin());System.out.println("所有数之和 : " + stats.getSum());System.out.println("平均数 : " + stats.getAverage());

4.并行流

4.1并行流操作

流操作可以是顺序的,也可以是并行的。顺序操作通过单线程执行,而并行操作则通过多线程执行。

package com.jimi.java8.streamapi;import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;/*** @author test*/
public class ParallelStreamAndStream {public static void main(String[] args) {List<Integer> i = Arrays.asList(1, 2, 3, 4, 5, 6, 7);System.out.println("stream.forEach打印结果如下(有序)");i.stream().forEach(System.out::println);System.out.println("parallelStream.forEach打印结果如下(无序)");i.parallelStream().forEach(System.out::println);System.out.println("parallelStream.forEachOrdered打印结果如下(有序.结果同stream.forEac)");i.parallelStream().forEachOrdered(System.out::println);//模拟10000条数据 循环打印测试List<Integer> list = new ArrayList();for (int j = 0; j < 1000; j++) {list.add(j);}// 统计并行执行list的线程Set<Thread> threadSet = new CopyOnWriteArraySet<>();// 并行执行list.parallelStream().forEach(integer -> {Thread thread = Thread.currentThread();// 统计并行执行list的线程threadSet.add(thread);});System.out.println(threadSet);//打印结果由此证明parallelStream是多管道线程System.out.println("threadSet一共有" + threadSet.size() + "个线程");System.out.println("系统一个有" + Runtime.getRuntime().availableProcessors() + "个cpu");list.parallelStream().forEach(System.out::println);}
}

4.2 并行流效率测试

package com.jimi.java8.streamapi;import java.util.ArrayList;
import java.util.List;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
import java.util.concurrent.TimeUnit;/*** @author test*/
public class ParallelTime {public static void main(String[] args) throws InterruptedException {//模拟10000条数据 forEach打印测试List<Integer> list = new ArrayList();for (int j = 0; j < 10; j++) {list.add(j);}long startTime = System.currentTimeMillis();//传统for循环for (int i = 0; i < list.size(); i++) {try {//睡眠1毫秒TimeUnit.MILLISECONDS.sleep(1);} catch (Exception e) {e.printStackTrace();}}long endTime = System.currentTimeMillis();System.out.println("传统for循环运行时间:" + (endTime - startTime) + "ms");// 测试单管道stream执行效率startTime = System.currentTimeMillis();list.stream().forEach(r -> {try {//睡眠1毫秒TimeUnit.MILLISECONDS.sleep(1);} catch (Exception e) {e.printStackTrace();}});long streamendTime = System.currentTimeMillis();System.out.println("stream : " + (streamendTime - startTime) + "ms");// 测试多管道parallelStream执行效率startTime = System.currentTimeMillis();Set<Thread>  threads = new CopyOnWriteArraySet<>();list.parallelStream().forEach(r -> {try {Thread thread = Thread.currentThread();threads.add(thread);System.out.println("系统创建了"+threads.size()+"个线程");//睡眠1毫秒TimeUnit.MILLISECONDS.sleep(1);} catch (Exception e) {e.printStackTrace();}});long parallelStreamendTime = System.currentTimeMillis();System.out.println("parallelStream : " + (parallelStreamendTime - startTime) + "ms");}
}

并行流快了很多。但是我产生了另外的一个问题便是:有时候在排查错误的时候,流的形式不方便进行日志的监控。
在这里插入图片描述

4.3 最后啰嗦一句

ConcurrentModificationException总是会在使用迭代器且直接操作集合时产生

这篇关于java8新特性之数据流(串行流和并行流)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/891421

相关文章

基于SpringBoot+Mybatis实现Mysql分表

《基于SpringBoot+Mybatis实现Mysql分表》这篇文章主要为大家详细介绍了基于SpringBoot+Mybatis实现Mysql分表的相关知识,文中的示例代码讲解详细,感兴趣的小伙伴可... 目录基本思路定义注解创建ThreadLocal创建拦截器业务处理基本思路1.根据创建时间字段按年进

Java编译生成多个.class文件的原理和作用

《Java编译生成多个.class文件的原理和作用》作为一名经验丰富的开发者,在Java项目中执行编译后,可能会发现一个.java源文件有时会产生多个.class文件,从技术实现层面详细剖析这一现象... 目录一、内部类机制与.class文件生成成员内部类(常规内部类)局部内部类(方法内部类)匿名内部类二、

SpringBoot实现数据库读写分离的3种方法小结

《SpringBoot实现数据库读写分离的3种方法小结》为了提高系统的读写性能和可用性,读写分离是一种经典的数据库架构模式,在SpringBoot应用中,有多种方式可以实现数据库读写分离,本文将介绍三... 目录一、数据库读写分离概述二、方案一:基于AbstractRoutingDataSource实现动态

Springboot @Autowired和@Resource的区别解析

《Springboot@Autowired和@Resource的区别解析》@Resource是JDK提供的注解,只是Spring在实现上提供了这个注解的功能支持,本文给大家介绍Springboot@... 目录【一】定义【1】@Autowired【2】@Resource【二】区别【1】包含的属性不同【2】@

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J

Java中的String.valueOf()和toString()方法区别小结

《Java中的String.valueOf()和toString()方法区别小结》字符串操作是开发者日常编程任务中不可或缺的一部分,转换为字符串是一种常见需求,其中最常见的就是String.value... 目录String.valueOf()方法方法定义方法实现使用示例使用场景toString()方法方法

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("