Supplier 惰性调用和 Future#get 同步等待调用结合

时间:2024-01-25 14:27:31

????一、背景介绍

关于任务异步执行,两个点不可避免:异步结果和异步回调。

而在我的工程中有这样一段代码:使用 CompletableFuture 进行封装,可以异步执行,异步回调,通过 get() 等待异步任务的结果

注:任何方法都可以封装成 CallbackTask 调用。

Supplier 惰性调用和 Future#get 同步等待调用结合_代码优化

但用着用着就发现明显的不对劲,主线程会阻塞等待结果。异步转同步!

Supplier 惰性调用和 Future#get 同步等待调用结合_异步回调_02


Optional.ofNullable(invoke.get(DEFAULT_MAX_TIMEOUT, TimeUnit.SECONDS))。get() 方法会进行阻塞等待。invokeWithResult 封装得不是很理想

Supplier 惰性调用和 Future#get 同步等待调用结合_代码优化_03

有没有好的方法,不执行阻塞等待呢?直接返回 CompletableFuture 就可以了,等主线程用到的时候,再调用 CompletableFuture#get获取。

但用 CompletableFuture 作为方法返回值,个人觉得语义并不很好,有没有其他方式呢,带着这个问题过了一天,终于有了灵感 -- supplier 惰性求值。

????二、supplier 惰性

Supplier接口在 Java 中通常被用于实现惰性求值。Supplier的特点在于它的 get()方法,该方法没有输入参数,并在被调用时返回一个T类型的值。在Supplier 被定义时,并不会执行 get() 方法中的代码;只有在显式调用 get() 方法时,代码才会执行,并且生成并提供一个值。

Supplier 惰性调用和 Future#get 同步等待调用结合_异步结果_04

这允许代码在需要时才生成值,从而实现了惰性求值。因为Supplier推迟了执行,直到调用者准备好接收值,这可以提高性能,避免不必要的计算,尤其是在处理耗时的操作或创建资源密集型对象时。

一个简单的例子可以展示Supplier的惰性行为

Supplier 惰性调用和 Future#get 同步等待调用结合_异步结果_05

灵感来了,尝试用 supplier 来解决上面的问题。

????三、supplier 和 Future#get 结合

将 Future#get 用 supplier 表达,等需要异步结果的时候再从 supplier 中获取。

Supplier 惰性调用和 Future#get 同步等待调用结合_多线程_06

没错,supplier 达到效果。主线程使用 invokeWithSupplier 时不再堵塞。只是有 supplier#get才会阻塞获得结果值。

但为了更符合业务语义,进一步将 supplier 进行包装,用包装类承载结果

Supplier 惰性调用和 Future#get 同步等待调用结合_异步结果_07


用 AsyncResp 作为返回类型,最终方法如下:

Supplier 惰性调用和 Future#get 同步等待调用结合_异步回调_08

后来回顾,AsyncResp 甚至可以对 CompletableFuture 进行包装,如下所示:

Supplier 惰性调用和 Future#get 同步等待调用结合_异步回调_09

真的是,条条道路通罗马,多一些思考发现代码其实还挺有趣的!

异步、异步回调、异步结果是非常常见的问题,应用的场景也特别多,工程中常备此类工具。

对于 supplier 惰性能力,包装了 Future#get,觉得挺有意思的,决定把过程记录下来。

最后说一句(求关注!)

如果这篇文章对您有所帮助,或者有所启发的话,求一键三连:点赞、转发、在看。

关注公众号:woniuxgg,在公众号中回复:笔记  就可以获得蜗牛为你精心准备的java实战语雀笔记,回复面试、开发手册、有超赞的粉丝福利!