首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Java:Java 中的顺序流与并行流是什么?

Java 中的流是表示为数据管道的对象序列。它通常具有数据所在的源和传输的目的地。请注意,流不是存储库;相反,它对数据源(例如数组或集合)进行操作。段落中的中间位实际上称为流。

在传输过程中,流通常会经历一种或多种可能的转换,例如过滤或排序,也可以是对数据进行操作的任何其他过程。这通常根据程序员的需要将原始数据定制为不同的形式。因此,根据对其应用的操作创建一个新流。例如,当对流进行排序时,它会产生一个新流,该流会产生一个结果,然后再对其进行排序。这意味着新数据是原始数据的转换副本,而不是原始形式。

顺序流

除非明确指定为并行,否则 Java 中的任何流操作都是按顺序处理的。它们基本上是使用单个线程处理其管道的非并行流。即使底层系统可能支持并行执行,顺序流也永远不会利用多核系统。例如,当我们应用多线程处理流时会发生什么?即便如此,它一次只能在一个内核上运行。但是,除非明确固定到特定的核心,否则它可能会从一个核心跳到另一个核心。例如,四个不同线程与四个不同内核的处理显然是不同的,前者与后者不匹配。在单核环境中执行多个线程是完全可能的,但并行处理完全是一种不同的类型。除了在支持它的环境中执行之外,还需要为并行编程设计一个程序。这就是并行编程是一个复杂领域的原因。

并行流

使用并行流的主要动机是使流处理成为并行编程的一部分,即使整个程序可能没有并行化。并行流利用多核处理器,从而显着提高性能。与任何并行编程不同,它们复杂且容易出错。但是,Java 流库提供了以可靠的方式轻松完成此操作的能力。整个程序可能不会并行化。但至少处理流的部分可以并行化。从某种意义上说,它们实际上非常简单,我们可以调用一些方法,其余的都可以处理。有几种方法可以做到这一点。一种这样的方法是通过调用 Collection 定义的 parallelStream() 方法来获取并行流。另一种方法是在顺序流上调用 BaseStream 定义的 parallel() 方法。顺序流由调用并行化。请注意,底层平台必须支持并行编程,例如多核系统。否则,调用没有意义。在这种情况下,流将按顺序处理,即使我们已经进行了调用。如果调用是在已经并行的流上进行的,它什么也不做,只是简单地返回流。

为了保证对流应用并行处理的结果与通过顺序处理得到的结果相同,并行流必须是无状态的、无干扰的和关联的。

结论

流 API 长期以来一直是 Java 的一部分,但是添加并行处理的调整非常受欢迎,同时也是一个非常有趣的特性。尤其如此,因为现代机器是多核的,并且并行编程设计很复杂是一个耻辱。Java 提供的 API 提供了在具有顺序执行的整体设计的 Java 程序中加入一些并行编程调整的能力。这可能是此功能的最佳部分。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20220429A0353P00?refer=cp_1026
  • 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。
  • 如有侵权,请联系 cloudcommunity@tencent.com 删除。

扫码

添加站长 进交流群

领取专属 10元无门槛券

私享最新 技术干货

扫码加入开发者社群
领券