Java Stream:计数始终是计数吗?
它可能会出现明显的是,在计数的元素Stream
需要较长时间的多个元素中有Stream
。 但实际上,
Stream::count
有时可以在一个操作中完成,无论您有多少元素。 阅读本文并了解操作方法。
计数复杂度
Stream::count
终端操作对a中的元素数进行计数
Stream
。 运算的复杂度通常为O(N)
,这意味着子运算的数量与运算中元素的数量成正比。
Stream
。
相反, List::size
方法的复杂度为O(1)
,这意味着无论List
中元素的数量如何, size()
方法都会在恒定时间内返回。 通过运行以下JMH基准可以观察到这一点:
@State (Scope.Benchmark) public class CountBenchmark { private List<Integer> list; @Param ({ "1" , "1000" , "1000000" }) private int size; @Setup public void setup() { list = IntStream.range( 0 , size) .boxed() .collect(toList()); } @Benchmark public long listSize() { return list.size(); } @Benchmark public long listStreamCount() { return list.stream().count(); } public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() .include(CountBenchmark. class .getSimpleName()) .mode(Mode.Throughput) .threads(Threads.MAX) .forks( 1 ) .warmupIterations( 5 ) .measurementIterations( 5 ) .build(); new Runner(opt).run(); } }
这在我的笔记本电脑(2015年中的MacBook Pro,2.2 GHz Intel Core i7)上产生了以下输出:
Benchmark (size) Mode Cnt Score Error Units CountBenchmark.listSize 1 thrpt 5 966658591.905 ± 175787129.100 ops/s CountBenchmark.listSize 1000 thrpt 5 862173760.015 ± 293958267.033 ops/s CountBenchmark.listSize 1000000 thrpt 5 879607621.737 ± 107212069.065 ops/s CountBenchmark.listStreamCount 1 thrpt 5 39570790.720 ± 3590270.059 ops/s CountBenchmark.listStreamCount 1000 thrpt 5 30383397.354 ± 10194137.917 ops/s CountBenchmark.listStreamCount 1000000 thrpt 5 398.959 ± 170.737 ops/s
<br>
可以看出, List::size
的吞吐量在很大程度上与List
中元素的数量无关,而Stream::count
的吞吐量随着元素数量的增加而Swift下降。 但是,实际上所有Stream
实现本身总是如此吗?
源感知流
一些流实现实际上知道它们的源,并且可以采用适当的快捷方式并将流操作合并到流源本身中。 这可以极大地提高性能,尤其是对于大型流。 Speedment ORM工具允许将数据库视为Stream对象,并且这些流可以优化许多流操作,如Stream::count
操作,如下面的基准所示。 我已使用开源Sakila示例数据库作为数据输入。 Sakila数据库包含有关租赁电影,艺术家等的全部信息。
@State (Scope.Benchmark) public class SpeedmentCountBenchmark { private Speedment app; RentalManager rentals; private RentalManager rentals; private FilmManager films; @Setup public void setup() { app = new SakilaApplicationBuilder() .withBundle(DataStoreBundle. class ) .withLogging(ApplicationBuilder.LogType.STREAM) .withPassword(ExampleUtil.DEFAULT_PASSWORD) .build(); app.get(DataStoreComponent. class ).ifPresent(DataStoreComponent::load); rentals = app.getOrThrow(RentalManager. class ); films = app.getOrThrow(FilmManager. class ); } @TearDown public void tearDown() { app.close(); } @Benchmark public long rentalsCount() { return rentals.stream().count(); } @Benchmark public long filmsCount() { return films.stream().count(); } public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() .include(SpeedmentCountBenchmark. class .getSimpleName()) .mode(Mode.Throughput) .threads(Threads.MAX) .forks( 1 ) .warmupIterations( 5 ) .measurementIterations( 5 ) .build(); new Runner(opt).run(); } }
运行时,将产生以下输出:
Benchmark Mode Cnt Score Error Units SpeedmentCountBenchmark.filmsCount thrpt 5 71037544.648 ± 75915974.254 ops/s SpeedmentCountBenchmark.rentalsCount thrpt 5 69750012.675 ± 37961414.355 ops/s
<br>
<br>
“租赁”表包含10,000行,而“电影”表仅包含1,000行。 但是,它们的Stream::count
操作几乎在同一时间完成。 即使一个表包含一万亿行,它仍然会在相同的经过时间内对元素进行计数。 就这样
Stream::count
实现的复杂度为O(1)
而不是
O(N)
注意:上面的基准测试是通过Speedment的“ DataStore” JVM虚拟机内存加速来运行的。 如果直接对数据库没有加速运行,则响应时间将取决于基础数据库执行“SELECT count(*) FROM film”
查询的能力。
摘要
可以创建在单个操作中对元素进行计数的Stream
实现,而不是对流中的每个元素进行计数。 这可以显着提高性能,尤其是对于具有许多元素的流。
资源资源
Speedment Stream ORM初始化程序: https ://www.speedment.com/initializer/
Sakila: https ://dev.mysql.com/doc/index-other.html或https://hub.docker.com/r/restsql/mysql-sakila
翻译自: https://www.javacodegeeks.com/2019/04/java-stream-count-always-count.html
Java Stream:计数始终是计数吗?相关推荐
- Java Stream:第2部分,计数始终是计数吗?
在上一篇有关该主题的文章中 ,我们了解到JDK 8 stream()::count需要更长的时间来执行Stream更多的元素. 对于较新的JDK(例如Java 11),简单流管道不再是这种情况. 了解 ...
- stream分组计数_Java Stream:第2部分,计数始终是计数吗?
stream分组计数 在上一篇有关该主题的文章中 ,我们了解到JDK 8 stream()::count需要更长的时间来执行Stream更多的元素. 对于最新的JDK(例如Java 11),简单的流管 ...
- java Stream 流
java Stream 流 Stream 流 流的创建 流的转化 Optianal 流的计算 Stream 流 1. Stream的定义 来自数据源的支持聚合操作的元素序列. 即一个流对外提供接口,接 ...
- java stream order by_Java Stream 使用详解
Stream是 Java 8新增加的类,用来补充集合类. Stream代表数据流,流中的数据元素的数量可能是有限的,也可能是无限的. Stream和其它集合类的区别在于:其它集合类主要关注与有限数量的 ...
- 深度掌握 Java Stream 流操作,让你的代码高出一个逼格
概念 Stream将要处理的元素集合看作一种流,在流的过程中,借助Stream API对流中的元素进行操作,比如:筛选.排序.聚合等. Stream` 的操作符大体上分为两种:`中间操作符`和`终止操 ...
- 这个方法可以让你的代码高出一个逼格——掌握 Java Stream 流操作
概念 Stream将要处理的元素集合看作一种流,在流的过程中,借助Stream API对流中的元素进行操作,比如:筛选.排序.聚合等. Stream` 的操作符大体上分为两种:`中间操作符`和`终止操 ...
- Java Stream的流操作,居然让我的代码越写越丝滑?
概念 Stream将要处理的元素集合看作一种流,在流的过程中,借助Stream API对流中的元素进行操作,比如:筛选.排序.聚合等. Stream` 的操作符大体上分为两种:`中间操作符`和`终止操 ...
- 优雅代码的秘密,只因为我掌握了Java Stream 流操作
概念 Stream将要处理的元素集合看作一种流,在流的过程中,借助Stream API对流中的元素进行操作,比如:筛选.排序.聚合等. Stream` 的操作符大体上分为两种:`中间操作符`和`终止操 ...
- Java 代码写的又臭又长,还不会用 Java Stream 函数式编程?
点击上方"猿芯",选择"设为星标" 后台回复"1024",有份惊喜送给面试的你 原文 https://www.cnblogs.com/Car ...
最新文章
- pthread_create如何传递两个参数以上的参数
- SAP ERP和C4C Acount和Contact的双向同步
- TCP/IP:IP多播选路
- 前端学习(3199):jsx小练习
- QC无法启动,实战记录
- [LOJ#6053]简单的函数 题解
- javascript canvas生成分形图练习
- python使用有道翻译API翻译
- 80后的你现在有多少资产?
- oracle 常用语句2
- 图像预处理的一般步骤
- System.Data.SqlClient.SqlError: Exclusive access could not be obtained because the database is in us
- 新闻文化建设杂志新闻文化建设杂志社新闻文化建设编辑部2022年第14期目录
- App Designer中自建回调函数
- 织梦cms内容采集视频教程
- BT种子怎么用 BT种子怎么下载 BT种子是什么意思
- 绝对定位后的DIV水平居中
- 概率论与统计推断(四) ------ 统计推断
- 2020起重机司机(限桥式起重机)考试题及起重机司机(限桥式起重机)实操考试视频
- 什么品牌的游戏蓝牙耳机比较好?玩游戏延迟低的蓝牙耳机推荐