type
status
date
urlname
summary
tags
category
icon
password
catalog
sort
异步执行对于开发者来说并不陌生,在实际的开发过程中,很多场景多会使用到异步,相比同步执行,异步可以大大缩短请求链路耗时时间,比如:发送短信、邮件、异步更新等,这些都是典型的可以通过异步实现的场景。
异步的八种实现方式
- 线程Thread
- Future
- 异步框架CompletableFuture
- Spring注解@Async
- Spring ApplicationEvent事件
- 消息队列
- 第三方异步框架,比如Hutool的ThreadUtil
- Guava异步
什么是异步?
首先我们先看一个常见的用户下单的场景:
在同步操作中,我们执行到 发送短信 的时候,我们必须等待这个方法彻底执行完才能执行 赠送积分 这个操作,如果 赠送积分 这个动作执行时间较长,发送短信需要等待,这就是典型的同步场景。
实际上,发送短信和赠送积分没有任何的依赖关系,通过异步,我们可以实现
赠送积分
和发送短信
这两个操作能够同时进行,比如:这就是所谓的异步,是不是非常简单,下面就说说异步的几种实现方式吧。
异步编程
4.1 线程异步
当然如果每次都创建一个
Thread
线程,频繁的创建、销毁,浪费系统资源,我们可以采用线程池:可以将业务逻辑封装到
Runnable
或Callable
中,交由线程池来执行。4.2 Future异步
输出结果:
4.2.1 Future的不足之处
Future的不足之处的包括以下几点:
1️⃣ 无法被动接收异步任务的计算结果:虽然我们可以主动将异步任务提交给线程池中的线程来执行,但是待异步任务执行结束之后,主线程无法得到任务完成与否的通知,它需要通过get方法主动获取任务执行的结果。
2️⃣ Future件彼此孤立:有时某一个耗时很长的异步任务执行结束之后,你想利用它返回的结果再做进一步的运算,该运算也会是一个异步任务,两者之间的关系需要程序开发人员手动进行绑定赋予,Future并不能将其形成一个任务流(pipeline),每一个Future都是彼此之间都是孤立的,所以才有了后面的CompletableFuture,CompletableFuture就可以将多个Future串联起来形成任务流。
3️⃣ Futrue没有很好的错误处理机制:截止目前,如果某个异步任务在执行发的过程中发生了异常,调用者无法被动感知,必须通过捕获get方法的异常才知晓异步任务执行是否出现了错误,从而在做进一步的判断处理。
4.3 CompletableFuture实现异步
我们不需要显式使用ExecutorService,CompletableFuture 内部使用了
ForkJoinPool
来处理异步任务,如果在某些业务场景我们想自定义自己的异步线程池也是可以的。4.4 Spring的@Async异步
4.4.1 自定义异步线程池
4.4.2 AsyncService
在实际项目中, 使用
@Async
调用线程池,推荐等方式是是使用自定义线程池的模式,不推荐直接使用@Async直接实现异步,因为springboot默认的线程池中只有一个常驻线程4.5 Spring ApplicationEvent事件实现异步
4.5.1 定义事件
4.5.2 定义事件处理器
另外,可能有些时候采用ApplicationEvent实现异步的使用,当程序出现异常错误的时候,需要考虑补偿机制,那么这时候可以结合Spring Retry重试来帮助我们避免这种异常造成数据不一致问题。
4.6 消息队列
4.6.1 回调事件消息生产者
4.6.2 回调事件消息消费者
4.7 ThreadUtil异步工具类
4.8 Guava异步
Guava
的ListenableFuture
顾名思义就是可以监听的Future
,是对java原生Future的扩展增强。我们知道Future表示一个异步计算任务,当任务完成时可以得到计算结果。如果我们希望一旦计算完成就拿到结果展示给用户或者做另外的计算,就必须使用另一个线程不断的查询计算状态。这样做,代码复杂,而且效率低下。使用Guava ListenableFuture可以帮我们检测Future是否完成了,不需要再通过get()方法苦苦等待异步的计算结果,如果完成就自动调用回调函数,这样可以减少并发程序的复杂度。ListenableFuture
是一个接口,它从jdk
的Future
接口继承,添加了void addListener(Runnable listener, Executor executor)
方法。我们看下如何使用ListenableFuture。首先需要定义ListenableFuture的实例:
首先通过
MoreExecutors
类的静态方法listeningDecorator
方法初始化一个ListeningExecutorService
的方法,然后使用此实例的submit
方法即可初始化ListenableFuture
对象。ListenableFuture
要做的工作,在Callable接口的实现类中定义,这里只是休眠了1秒钟然后返回一个数字1,有了ListenableFuture实例,可以执行此Future并执行Future完成之后的回调函数。- 作者:Honesty
- 链接:https://blog.hehouhui.cn/archives/java-sync-introduce-1104
- 声明:本文采用 CC BY-NC-SA 4.0 许可协议,转载请注明出处。
相关文章