一、简介1.1概述在上一篇文章《CompletionService使用与源码分析》中，已经介绍过了Future的局限性，它没法直接对多个任务进行链式、组合等处理，需要借助并发工具类才能完成，实现逻辑比较复杂。而CompletableFuture是对Future的扩展和增强。CompletableFuture实现了Future接口，并在此基础上进行了丰富的扩展，完美弥补了Future的局限性，同时CompletableFuture实现了对任务编排的能力。借助这项能力，可以轻松地组织不同任务的运行顺序、规则以及方式。从某种程度上说，这项能力是它的核心能力。而在以往，虽然通过CountDownLat

背景介绍为什么需要学习Java并发？从提升性能角度来说提升了对CPU的使用效率：目前生产的服务器大多数都是多核，标配的机器都是8C/16G。操作系统会将不同的线程分配给不同的核心处理，理论上，有多少核心就有多少个线程并行执行。如果没有并发编程，CPU的利用率将极大的浪费，假设当前正在处理耗时的I/O操作，那么整个CPU就会处于阻塞空闲状态，后面的指令必须等待前面的执行完才能继续执行。降低服务RT：大型互联网访问量轻松每秒轻松过万，如果没有并发处理，所有的用户请求都会排队等待，那种体验效果你能想象么，这样的服务能力如何能留住客户？有了并发编程，充分释放CPU算力，操作系统让每个客户轮流使用CPU

背景介绍为什么需要学习Java并发？从提升性能角度来说提升了对CPU的使用效率：目前生产的服务器大多数都是多核，标配的机器都是8C/16G。操作系统会将不同的线程分配给不同的核心处理，理论上，有多少核心就有多少个线程并行执行。如果没有并发编程，CPU的利用率将极大的浪费，假设当前正在处理耗时的I/O操作，那么整个CPU就会处于阻塞空闲状态，后面的指令必须等待前面的执行完才能继续执行。降低服务RT：大型互联网访问量轻松每秒轻松过万，如果没有并发处理，所有的用户请求都会排队等待，那种体验效果你能想象么，这样的服务能力如何能留住客户？有了并发编程，充分释放CPU算力，操作系统让每个客户轮流使用CPU

17|异步RPC：压榨单机吞吐量在我们知道RPC框架基础知识后，我们需要从RPC框架整体性能去考虑问题，例如怎么提升RPC框架的性能、稳定性、安全性、吞吐量，以及如何在分布式的场景下快速定位问题等。影响RPC调用吞吐量的根本原因是什么？处理RPC请求比较耗时，并且CPU大部分时间都在等待而非去计算，从而导致CPU利用率不高。RPC请求的耗时大部分是业务耗时，比如业务逻辑中有访问数据库执行慢SQL的操作，所以我们要看怎么能提升业务逻辑处理。要提升吞吐量，关键就两个字：异步。服务调用端怎么异步？对于调用端来说，向服务端发送请求消息与接受服务端发送过来的响应消息，这两个处理过程是两个完全独立的过程，

17|异步RPC：压榨单机吞吐量在我们知道RPC框架基础知识后，我们需要从RPC框架整体性能去考虑问题，例如怎么提升RPC框架的性能、稳定性、安全性、吞吐量，以及如何在分布式的场景下快速定位问题等。影响RPC调用吞吐量的根本原因是什么？处理RPC请求比较耗时，并且CPU大部分时间都在等待而非去计算，从而导致CPU利用率不高。RPC请求的耗时大部分是业务耗时，比如业务逻辑中有访问数据库执行慢SQL的操作，所以我们要看怎么能提升业务逻辑处理。要提升吞吐量，关键就两个字：异步。服务调用端怎么异步？对于调用端来说，向服务端发送请求消息与接受服务端发送过来的响应消息，这两个处理过程是两个完全独立的过程，

作者：京东科技张天赐前言JDK8是一次重大的版本升级，新增了非常多的特性，其中之一便是 CompletableFuture。自此从JDK层面真正意义上的支持了基于事件的异步编程范式，弥补了 Future 的缺陷。在我们的日常优化中，最常用手段便是多线程并行执行。这时候就会涉及到 CompletableFuture 的使用。常见使用方式下面举例一个常见场景。假如我们有两个RPC远程调用服务，我们需要获取两个RPC的结果后，再进行后续逻辑处理。publicstaticvoidmain(String[]args){//任务A，耗时2秒intresultA=compute(1);//任务B，耗时2秒i

作者：京东科技张天赐前言JDK8是一次重大的版本升级，新增了非常多的特性，其中之一便是 CompletableFuture。自此从JDK层面真正意义上的支持了基于事件的异步编程范式，弥补了 Future 的缺陷。在我们的日常优化中，最常用手段便是多线程并行执行。这时候就会涉及到 CompletableFuture 的使用。常见使用方式下面举例一个常见场景。假如我们有两个RPC远程调用服务，我们需要获取两个RPC的结果后，再进行后续逻辑处理。publicstaticvoidmain(String[]args){//任务A，耗时2秒intresultA=compute(1);//任务B，耗时2秒i

最近一直畅游在RocketMQ的源码中，发现在RocketMQ中很多地方都使用到了CompletableFuture，所以今天就跟大家来聊一聊JDK1.8提供的异步神器CompletableFuture，并且最后会结合RocketMQ源码分析一下CompletableFuture的使用。Future接口以及它的局限性我们都知道，Java中创建线程的方式主要有两种方式，继承Thread或者实现Runnable接口。但是这两种都是有一个共同的缺点，那就是都无法获取到线程执行的结果，也就是没有返回值。于是在JDK1.5以后为了解决这种没有返回值的问题，提供了Callable和Future接口以及Fu

最近一直畅游在RocketMQ的源码中，发现在RocketMQ中很多地方都使用到了CompletableFuture，所以今天就跟大家来聊一聊JDK1.8提供的异步神器CompletableFuture，并且最后会结合RocketMQ源码分析一下CompletableFuture的使用。Future接口以及它的局限性我们都知道，Java中创建线程的方式主要有两种方式，继承Thread或者实现Runnable接口。但是这两种都是有一个共同的缺点，那就是都无法获取到线程执行的结果，也就是没有返回值。于是在JDK1.5以后为了解决这种没有返回值的问题，提供了Callable和Future接口以及Fu

hello，大家好呀，我是小楼。最近一个技术群有同学at我，问我是否熟悉Dubbo，这我熟啊~他说遇到了一个Dubbo异步调用的问题，怀疑是个BUG，提到BUG我可就不困了，说不定可以水，哦不...写一篇文章。问题复现遇到问题，尤其不是自己遇到的，必须要复现出来才好排查，截一个当时的聊天记录：他的问题原话是：今天发现一个问题有一个dubbo接口返回类型是boolean，把接口从同步改成异步server端返回true消费端却返回false，把boolean改成Boolean就能正常返回结果有碰到过这个问题吗注意几个重点：接口返回类型是boolean同步改为异步调用返回的boolean和预期不符合