java 多线程和并行编程_Java 8中的并行和异步编程
java 多线程和并行编程
并行代码是在多个线程上运行的代码,曾经是许多经验丰富的开发人员的噩梦,但是Java 8带来了许多更改,这些更改应该使这种提高性能的窍门更加易于管理。
并行流
在Java 8之前,并行(或并发)代码与顺序代码之间存在很大差异。 调试非顺序代码也非常困难。 像通常那样简单地设置一个断点并按照流程进行操作,将删除并行方面,如果这是导致该错误的原因,那么这是一个问题。
幸运的是,Java 8为我们提供了流,这是自Bean以来对Java开发人员而言最大的事情。 如果您不知道它们是什么,则Stream API可以处理功能问题中的元素序列。 (在这里检查流与.NET的LINQ之间的比较。)流的优点之一是代码的结构保持不变:无论是顺序的还是并发的,它都保持可读性。
为了使您的代码并行运行,只需使用.parallelStream()
而不是.stream()
(或者,如果您不是流的创建者,则可以使用stream
.parallel()
)。
但是,仅仅因为它很容易,并不意味着并行代码始终是最佳选择。 您应该始终考虑在代码段中使用并发是否有意义。 该决定中最重要的因素将是速度:仅当并发使您的代码比其顺序对应的代码快时才使用并发。
速度问题
并行代码通过使用多个线程而不是顺序代码使用的单个线程而获得了速度优势。 确定创建多少个线程可能是一个棘手的问题,因为更多的线程并不总是会导致更快的代码:如果使用太多的线程,则代码的性能实际上可能会下降。
有几条规则可以告诉您选择多少线程。 这主要取决于您要执行的操作类型以及可用内核的数量。
计算密集型操作应使用少于或等于内核数的线程数量,而IO密集型操作(如复制文件)对CPU无效,因此可以使用更多线程。 该代码不知道哪种情况适用,除非您告诉它该怎么做。 否则,它将默认为线程数等于内核数。
在两种主要情况下,并行运行代码而不是顺序运行代码很有用:耗时的任务和在大集合上运行的任务。 Java 8带来了一种处理大集合的新方法,即使用流。 流具有惰性的内置效率:它们使用惰性评估,通过做不必要的事情来节省资源。 这与并行性不同,只要它运行得更快,它就不会在乎资源。 因此,对于大型集合,您可能不需要经典的并行性。
================================================== ====================
异步
JavaScript的教训
Java开发人员很少会说他们从看过JavaScript中学到了什么,但是在异步编程方面,JavaScript实际上是正确的。 作为一种从根本上异步的语言,JavaScript在实施不好时会带来多大痛苦。 它从回调开始,后来被Promise取代。 许诺的一个重要好处是它有两个“通道”:一个用于数据,另一个用于错误。 JavaScript承诺可能看起来像这样:
func
.then(f1)
.catch(e1)
.then(f2)
.catch(e2);
因此,当原始函数获得成功结果时,将调用f1,但是如果引发错误,则将调用e1。 这可能会使它返回成功轨道(f2),或导致另一个错误(e2)。 您可以从数据跟踪到错误跟踪再返回。
JavaScript承诺的Java版本称为CompletableFuture 。
未来发展
CompletableFuture
同时实现Future
和CompletionStage
接口。 Java8之前就已经存在Future
,但是它本身对开发人员并不十分友好。 您只能使用.get()
方法来获取异步计算的结果,该方法会阻塞其余部分(使异步部分大部分时间变得毫无意义),并且您需要手动实现每种情况。 添加CompletionStage
接口是使Java异步编程可行的突破。
CompletionStage
是一个承诺,即最终将完成计算的承诺。 它包含许多方法,可让您附加将在完成时执行的回调。 现在我们可以处理结果而不会阻塞。
有两种主要方法可让您启动代码的异步部分: supplyAsync
如果您想对方法的结果进行某些操作)和runAsync
如果您不想这样做)。
CompletableFuture.runAsync(() → System.out.println("Run async in completable future " + Thread.currentThread()));
CompletableFuture.supplyAsync(() → 5);
回呼
现在,您可以添加这些回调以处理supplyAsync的结果
CompletableFuture.supplyAsync(() → 5)
.thenApply(i → i * 3)
.thenAccept(i → System.out.println(“The result is “ + i)
.thenRun(() → System.out.println("Finished."));
.thenApply
与.thenApply
的.map
函数类似:它执行转换。 在上面的示例中,它将结果(5)乘以3。然后将结果(15)进一步传递给管道。
.thenAccept
对结果执行一种方法,而无需对其进行转换。 它也不会返回结果。 它将在控制台上显示“结果为15”。 可以将它与.foreach
方法进行流比较。
.thenRun
不使用异步操作的结果,也不返回任何内容,它只是等待调用其Runnable
直到上一步完成为止。
异步处理
上面所有的回调方法也都具有异步版本: thenRunAsync
, thenApplyAsync
等。这些版本可以在自己的线程上运行,它们为您提供了额外的控制权,因为您可以告诉它使用哪个ForkJoinPool
。
如果不使用异步版本,则所有回调将在同一线程上执行。
当事情出错时
当出现问题时,将使用exceptionally
方法来处理异常。 您可以给它提供一个方法,该方法返回一个值以返回数据轨道,或引发(新)异常。
…
.exceptionally(ex → new Foo())
.thenAccept(this::bar);
合并与撰写
您可以使用thenCompose
方法链接多个CompletableFutures
。 没有它,结果将嵌套CompletableFutures
。 这使得thenCompose
和thenApply
像flatMap
和map
用于流。
CompletableFuture.supplyAsync(() -> "Hello")
.thenCompose(s -> CompletableFuture
.supplyAsync(() -> s + "World"));
如果要合并两个CompletableFutures
的结果,则需要一个方便地称为thenCombine
的方法。
future.thenCombine(future2, Integer::sum)
.thenAccept(value → System.out.println(value));
如您在上面的示例中看到的那样,可以使用所有喜欢的CompletionStage
方法像普通的CompletableFuture
一样处理thenCombine
中的回调结果。
结论
在寻求更快的代码时,并行编程不再是不可克服的障碍。 Java 8使该过程尽可能简单明了,因此,可能从中受益的任何代码都可以在所有线程上被拉,踢和尖叫,进入多核未来,实际上,这只是现在天。 我的意思是:这很容易做到,因此请尝试一下,看看自己的优势。
翻译自: https://www.javacodegeeks.com/2018/04/parallel-and-asynchronous-programming-in-java-8.html
java 多线程和并行编程
java 多线程和并行编程_Java 8中的并行和异步编程相关推荐
- Java 8中的并行和异步编程
并行代码是在多个线程上运行的代码,曾经是许多经验丰富的开发人员的噩梦,但是Java 8带来了许多更改,这些更改应该使这种提高性能的技巧更加易于管理. 并行流 在Java 8之前,并行(或并发)代码与顺 ...
- 阿里技术专家加多:Java异步编程实战之基于JDK中的Future实现异步编程 | 文末赠书...
正文共:14244 字 8 图 预计阅读时间: 36 分钟 本节内容摘自<Java异步编程实战>中的一小节. 一.前言 本节主要讲解如何使用JDK中的Future实现异步编程,这包含如何使 ...
- 阿里技术专家加多:Java异步编程实战之基于JDK中的Future实现异步编程
正文共:14244 字 8 图 预计阅读时间: 36 分钟 本节内容摘自<Java异步编程实战>中的一小节. 一.前言 本节主要讲解如何使用JDK中的Future实现异步编程,这包含如何使 ...
- java io使用哪些设计模式_JAVA IO中的设计模式
在java语言 I/O库的设计中,使用了两个结构模式,即装饰模式和适配器模式. 在任何一种计算机语言中,输入/输出都是一个很重要的部分.与一般的计算机语言相比,java将输入/输出的功能和使用范畴做了 ...
- java 多线程使用线程池_Java多线程:如何开始使用线程
java 多线程使用线程池 什么是线程? (What is a Thread?) A thread is a lightweight process. Any process can have mul ...
- java 同时修改同一个数据_Java 语言中锁的设计与应用
前言 Java提供了种类丰富的锁,每种锁因其特性的不同,在适当的场景下能够展现出非常高的效率.本文旨在对锁相关源码(本文中的源码来自JDK 8).使用场景进行举例,为读者介绍主流锁的知识点,以及不同的 ...
- java 多线程合并结果集_java多线程-合并
java多线程-合并 线程合并的意义就是几个并行的线程合并为一个单线程执行,应用于一个线程必须等待另个线程执行完毕后执行 例题:现有一个主线程,T1,T2怎么让T2在T1之后执行,主线程在T2之后执行 ...
- java 多线程的基本概念_java基本教程之多线程基本概念 java多线程教程
多线程是Java中不可避免的一个重要主体.下面我们将展开对多线程的学习.接下来的内容,是对"JDK中新增JUC包"之前的Java多线程内容的讲解,涉及到的内容包括,Object类中 ...
- java集合类的线程安全_Java集合中的线程安全问题
介绍 JDK中提供了很多集合实现,本文不会介绍有哪些集合的接口以及实现类,而是介绍如何在多线程情况下使用这些集合. - 如果您还不太了解Java的整个集合体系的话,请查看<Java开发成长之路第 ...
最新文章
- [置顶] ActivityGroup自我堆栈管理(复用现有activity)
- oracle手工收集awr报告_WHAT——什么是AWR?
- linux终端命令教程,Linux终端命令入坑技巧
- Java web后端2 Servlet Maven HttpServlet ServletConfig ServletContext HTTP协议
- 肝了1W字!文本生成评价指标的进化与推翻
- 【热修复】Andfix源码分析
- (计算机组成原理)第三章存储系统-第四节:主存储器和CPU的连接
- CDN缓存服务器现状
- python 当前目录_Python中的搜索路径顺序
- java容器类添加元素失败失败_java容器 Set
- python pygame鼠标点击_pygame系列_mouse鼠标事件
- 如何救队友_PS4《高达EXVSMBON》:如何违抗拥有巴力的他?
- laravel框架安装多国语言包
- MYSQL Error:You must SET PASSWORD before execut...
- etoken显示连接服务器失败,etoken
- Mac终端命令和连接服务器
- nginx的access.log文件详解
- android中常见对话框之一AlertDialog
- linux如何重新分区
- Failed to execute ‘getRangeAt‘ on ‘Selection‘: 0 is not a valid index.“报错
热门文章
- [COCI2017-2018#5] Karte
- 8.16模拟:树上算法
- 不止代码:路径数量(ybtoj-最小生成树)
- jzoj6297-世界第一的猛汉王【切比雪夫距离,扫描线】
- jzoj4235-序列【斐波那契数列】
- The 2020 ICPC Asia Macau Regional Contest J. Jewel Grab(数颜色+链表)
- 2017西安交大ACM小学期数据结构 [树状数组,极大值]
- 2017西安交大ACM小学期数据结构 [线段树]
- 搞定所有的跨域请求问题
- JavaFX图表(二)之饼图