皮皮网

1.Vert.x 源码解析(4.x)——Future源码解析
2.ModuleNotFoundError: No module named 'future'
3.ListenableFuture源码解析
4.研发必会-异步编程利器之CompletableFuture(含源码 中)

Vert.x 源码解析(4.x)——Future源码解析

       在现代软件开发中，异步编程的码f码分重要性日益凸显，提升并发性能并处理大量并行操作。码f码分Vert.x，码f码分作为一款基于事件驱动和非阻塞设计的码f码分异步框架，提供了丰富的码f码分qtcreator设置源码工具简化异步编程。本文将深入解析Vert.x 4.x版本的码f码分Future源码，理解其关键类和功能。码f码分

       1. 异步核心

       Vert.x的码f码分核心在于FutureImpl和PromiseImpl，它们是码f码分实现异步操作的关键。AsyncResult是码f码分通用接口，用于表示异步操作的码f码分结果，包含成功值或失败异常。码f码分

       2. Future类详解

       Future扩展了AsyncResult，码f码分提供了组合操作如join、码f码分any、all和map等功能。内部的FutureInternal主要负责添加监听器，FutureBase负责执行监听器和转换函数。

       具体来说，FutureImpl的onComplete方法接收一个handler，任务完成后执行，而tryComplete则在异步操作有结果时触发，最终调用用户指定的vtk 源码githubhandler。

       相比之下，Promise允许用户手动设置异步结果，PromiseImpl继承自FutureImpl，并增加了context获取功能。

       3. 实例与源码分析

       通过简单的入门实例，如独立使用Future，我们可以看到Vert.x如何通过创建PromiseImpl获取Future。源码分析显示，Promise.future获取Future，OnComplete用于添加监听，而complete方法则用于设置值并通知监听器。

       4. 深入源码

       在源码层面，addListener和emitSuccess方法在OnComplete中扮演重要角色。而complete方法，特别是tryComplete，是设置值并触发监听的关键。

       5. 总结

       总的来说，理解Vert.x中的Future，就是创建PromiseImpl获取Future，通过OnComplete添加监听器，然后通过Promise的complete方法设置值并通知监听器。后续还将深入探讨其他Future实现类，如all、直播源码解析any和map的原理。

ModuleNotFoundError: No module named 'future'

       è§£åŽ‹xlwt-future-0.8.0.tar 你参考下 xlwt-future-0.8.0/xlwt/examples 下的例子是怎么用的就知道了

ListenableFuture源码解析

       ListenableFuture 是 spring 中对 JDK Future 接口的扩展，主要应用于解决在提交线程池的任务拿到 Future 后在 get 方法调用时会阻塞的问题。通过使用 ListenableFuture，可以向其注册回调函数（监听器），当任务完成时，触发回调。Promise 在 Netty 中也实现了类似的功能，用于处理类似 Future 的场景。

       实现 ListenableFuture 的关键在于 FutureTask 的源码解析。FutureTask 是实现 Future 接口的基础类，ListenableFutureTask 在其基础上做了扩展。其主要功能是在任务提交后，当调用 get 方法时能够阻塞当前业务线程，直到任务完成时唤醒。

       FutureTask 通过在内部实现一个轻量级的 Treiber stack 数据结构来管理等待任务完成的线程。这个数据结构由 WaitNode 节点组成，每个节点代表一个等待的线程。当业务线程调用 get 方法时，会将自己插入到 WaitNode 栈中，并且在插入的同时让当前线程进入等待状态。在任务执行完成后，会遍历 WaitNode 栈，java覆盖源码唤醒等待的线程。

       为了确保并发安全，FutureTask 使用 CAS（Compare and Swap）操作来管理 WaitNode 栈。每个新插入的节点都会使用 CAS 操作与栈顶节点进行比较，并在满足条件时更新栈顶。这一过程保证了插入操作的原子性，防止了并发条件下的数据混乱。同时，插入操作与栈顶节点的更新操作相互交织，确保了数据的一致性和完整性。

       在 FutureTask 中，还利用了 LockSupport 类提供的 park 和 unpark 方法来实现线程的等待和唤醒。当线程插入到 WaitNode 栈中后，通过 park 方法将线程阻塞；任务执行完成后，通过 unpark 方法唤醒线程，完成等待与唤醒的流程。

       综上所述，ListenableFuture 通过扩展 FutureTask 的功能，实现了任务执行与线程等待的高效管理。通过注册监听器并利用 CAS 操作与 LockSupport 方法，实现了在任务完成时通知回调，解决了异步任务执行时的线程阻塞问题，提高了程序的外贸 口罩 源码并发处理能力。

研发必会-异步编程利器之CompletableFuture(含源码 中)

       微信公众号访问地址： 研发必会-异步编程利器之CompletableFuture(含源码 中)

       近期热推文章：

       1、springBoot对接kafka,批量、并发、异步获取消息,并动态、批量插入库表;

       2、SpringBoot用线程池ThreadPoolTaskExecutor异步处理百万级数据;

       3、基于Redis的Geo实现附近商铺搜索(含源码)

       4、基于Redis实现关注、取关、共同关注及消息推送(含源码)

       5、SpringBoot整合多数据源，并支持动态新增与切换（详细教程）

       6、基于Redis实现点赞及排行榜功能

       7、研发必会-异步编程利器之CompletableFuture(上)

       一、多任务组合回调

       备注：源码获取方式在文底。

       1.1、AND组合关系

       thenCombine / thenAcceptBoth / runAfterBoth都表示：将两个CompletableFuture组合起来，只有这两个都正常执行完了，才会执行某个任务。也即：当任务一和任务二都完成再执行任务三(异步任务)。

       区别在于：

       1、runAfterBoth：不会把执行结果当做方法入参，且没有返回值。

       2、thenAcceptBoth：会将两个任务的执行结果作为方法入参，传递到指定方法中，且无返回值。

       3、thenCombine：会将两个任务的执行结果作为方法入参，传递到指定方法中，且有返回值。

       代码案例：

       运行结果：

       1.2、OR组合关系

       将两个CompletableFuture组合起来，只要其中一个执行完了，就会执行某个任务。（两个任务，只要有一个任务完成，就执行任务三）

       区别在于：

       1、runAfterEither：不会把执行结果当做方法入参，且没有返回值。

       2、acceptEither: 会将已经执行完成的任务，作为方法入参，传递到指定方法中，且无返回值。

       3、applyToEither：会将已经执行完成的任务，作为方法入参，传递到指定方法中，且有返回值。(个人推荐)

       参考代码：

       返回结果：

       若将异步任务中的Thread.sleep()改为，将输出的结果为：

       从结果中不难对比发现，任务的参数是任务和任务中执行最快的返回结果。

       注意：若把核心线程数量改为1，会是什么样的呢？

       运行结果：

       从上面看出，改为1就变成单线程执行了。

       1.3、多任务组合(allOf\anyOf)

       1.allOf：等待所有任务都执行完成后，才会执行 allOf 返回的CompletableFuture。如果任意一个任务异常，allOf的CompletableFuture，执行get方法，会抛出异常。(等待所有任务完成才会执行)

       2.anyOf:任意一个任务执行完，就执行anyOf返回的CompletableFuture。如果执行的任务异常，anyOf的CompletableFuture，执行get方法，会抛出异常。(只要有一个任务完成)

       参考案例：

       结果返回：

       从结果中看出：等待所有任务都执行完成后，才会执行 allOf 返回的CompletableFuture。

       同理anyOf，只需要调整代码：

       运行结果：

       1.4、thenCompose

       thenCompose方法会在某个任务执行完成后，将该任务的执行结果，作为方法入参，去执行指定的方法。该方法会返回一个新的CompletableFuture实例。

       1、如果该CompletableFuture实例的result不为null，则返回一个基于该result新的CompletableFuture实例；

       2、如果该CompletableFuture实例为null，然后就执行这个新任务。

       代码案例：

       结果：

       二、使用注意点

       CompletableFuture 使异步编程更加便利的、代码更加优雅的同时，也要关注使用的一些注意点。

       2.1、Future需要获取返回值，才能获取异常信息

       代码案例：

       输出结果：

       Future需要获取返回值(res.get())，才能获取到异常信息。如果不加 get()/join()方法，看不到异常信息。使用的时候，注意一下，考虑是否加try…catch…或者使用exceptionally方法。

       若改成exceptionally方法，无需get或join也可以捕获异常信息：

       结果：

       2.2、CompletableFuture的get()方法是阻塞的

       CompletableFuture的get()方法是阻塞的，如果使用它来获取异步调用的返回值，需要添加超时时间。

       推荐使用：

       2.3、建议使用自定义线程池，不要使用默认的

       CompletableFuture代码中使用了默认的线程池，处理的线程个数是电脑CPU核数-1。在大量请求过来的时候，处理逻辑复杂的话，响应会很慢。一般建议使用自定义线程池，优化线程池配置参数。

       参考案例：

       但是如果线程池拒绝策略是DiscardPolicy或者DiscardOldestPolicy，当线程池饱和时，会直接丢弃任务，不会抛弃异常。因此建议，CompletableFuture线程池策略最好使用AbortPolicy，然后耗时的异步线程，做好线程池隔离。

       说明：

       AbortPolicy（默认）：直接抛弃

       CallerRunsPolicy：用调用者的线程执行任务

       DiscardOldestPolicy：抛弃队列中最久的任务

       DiscardPolicy：抛弃当前任务。

       三、源码获取方式

       更多优秀文章，请关注个人微信公众号或搜索“程序猿小杨”查阅。然后回复：源码，可以获取对应的源码，开箱即可使用。

       如果大家对相关文章感兴趣，可以关注微信公众号"程序猿小杨"，会持续更新优秀文章!欢迎大家 分享、收藏、点赞、在看，您的支持就是我坚持下去的最大动力！谢谢!

       参考网站：

       blog.csdn.net/ThinkWon/...

       mp.weixin.qq.com/s/shjA...