【Java】异步回调转为同步返回
java
lock
condition
sync
callback
介绍
大家看完标题是不是觉得就是普通的Future
介绍,但如果我说这里的异步回调是指从外部调用服务的接口来回调,是不是实现同步就比较麻烦了
先给大家举个例子,对于我们现在物联网方向的开发,或多或少都会接触到物理设备的对接,甚至需要对设备进行控制等操作
但是有很大一部分设备是不会同步返回结果的,而是另外上报一条数据,这就非常难受了
对于前端页面的用户来说,在下发了一条命令之后,会更希望能直接得到命令响应结果,到底是成功还是失败
但是由于设备不会同步返回,就导致用户需要切换到其他页面去看设备响应是否成功
在最开始,因为没有更好的办法,所以我们预估了从命令下发一直到接收到数据上报的时间间隔,然后用Thread.sleep
来阻塞线程,不断查询是否上报了结果
可想而知,这种方式只能说是非常愚蠢,因为非常不好控制,如果等待时间设置的太短则可能导致大量请求返回不了结果,如果等待时间设置的太长则对于用户的体验就非常差
于是我就想有没有一种方式,能够在命令下发后就阻塞线程,直到数据上报再唤醒,这样就能非常精确的控制等待时间
所以我就写了一个工具来实现这样的功能
我们先来看看怎么使用吧
@RestController
@RequestMapping("/concept-sync-waiting")
public class SyncWaitingController {/*** 新建一个 {@link SyncWaitingConcept} 对象* 也可以直接在 Spring 容器中注入一个全局使用*/private final SyncWaitingConcept concept = new ConditionSyncWaitingConcept();/*** 下发命令,阻塞线程直到数据上报或超时** @param key 每条命令唯一的id* @return 设备上报的数据*/@RequestMapping("/send")public String send(@RequestParam String key) {try {return concept.waitSync(key, new SyncCaller() {@Overridepublic void call(Object k) {//在这里下发命令}}, 5000);} catch (SyncWaitingTimeoutException e) {return "下发命令超时";}}/*** 接收设备上报的数据,唤醒下发命令的线程** @param key 一般需要从上报数据中附带命令id* @param value 上报数据*/@RequestMapping("/receive")public void receive(@RequestParam String key, @RequestParam String value) {concept.notifyAsync(key, value);}
}
首先创建一个SyncWaitingConcept
对象,默认实现了ConditionSyncWaitingConcept
SyncWaitingConcept concept = new ConditionSyncWaitingConcept();
然后调用waitSync
方法,并阻塞当前线程
需要传入key
作为该次调用的标识(唯一id),SyncCaller
作为触发业务逻辑调用的接口,waitingTime
作为等待时间限制(小于等于0时则无限等待)
Object value = concept.waitSync(key, new SyncCaller() {@Overridepublic void call(Object k) {//自己的业务逻辑,并附带上key}}, 5000);
最后当接收到异步返回的数据时,调用notifyAsync
方法唤醒之前阻塞的线程即可得到接收到的数据
需要传入key
一般在返回数据中附带回来,value
作为接收到的数据
concept.notifyAsync(key, value);
是不是还是挺方便的,只要两个简单的方法就能阻塞和唤醒线程
如果大家有兴趣,Github上的介绍更加详细,还包括各种高级用法以及整体架构
思路
核心思路其实很简单,就是用Condition
来控制线程的阻塞和唤醒
await
方法可以阻塞当前的线程,进入等待队列,signalAll
方法可以唤醒队列中的所有线程
我把key
和对应的Condition
缓存在一个Map
中,当我们调用waitSync
方法时
- 先通过
key
查找是否存在等待中的Condition
- 如果已经存在,则调用
await
让当前线程排队阻塞 - 如果不存在,则调用回调接口中的业务逻辑
- 然后调用
await
让阻塞当前线程 - 接收数据,根据
key
获得对应的Condition
- 设置
key
对应的返回值并调用signalAll
唤醒线程 - 返回
key
得到的值 - 之前直接阻塞的线程也被唤醒并继续尝试执行
其他的文章
【Spring Cloud】协同开发利器之动态路由
【Spring Cloud】一个配置注解实现 WebSocket 集群方案
【Java】简单优雅的加载外部 jar 中的 Class|插件化
【Spring Boot】一个注解实现下载接口
【Spring Boot】WebSocket 的 6 种集成方式
【Java】异步回调转为同步返回相关推荐
- python同步异步,python异步回调转为同步并实现超时
用 Tornado 的话,写不了几行代码吧. 先作个简单的 Server ,以方便演示: # -*- coding: utf-8 -*- from tornado.ioloop import IOLo ...
- java异步接口转同步接口_如果今天设计了Java:同步接口
java异步接口转同步接口 Java已经走了很长一段路. 很长的路要走. 它带有早期设计决策中的所有"垃圾". 一遍又一遍后悔的一件事是, 每个对象(可能)都包含一个监视器 . 几 ...
- Java 异步回调机制实例解析
2019独角兽企业重金招聘Python工程师标准>>> 一.什么是回调 软件模块之间总是存在着一定的接口,从调用方式上,可以把他们分为三类:同步调用.回调和异步调用. 回调是一种特殊 ...
- java 异步查询转同步多种实现方式:循环等待,CountDownLatch,Spring EventListener,超时处理和空循环性能优化...
异步转同步 业务需求 有些接口查询反馈结果是异步返回的,无法立刻获取查询结果. 正常处理逻辑 触发异步操作,然后传递一个唯一标识. 等到异步结果返回,根据传入的唯一标识,匹配此次结果. 如何转换为同步 ...
- java异步回调历程
java I/O的经历了BIO(Blocking IO),NIO(Non-blocking IO),AIO(Async-I/O),这些IO技术的发展都是依托已java版本的更新. 本文主要研究一下ja ...
- java异步回调讲解
所谓回调:就是A类中调用B类中的某个方法M1,然后B类中反过来调用A类中的方法M2,M2这个方法就叫回调方法.实际在使用的时候,也会有不同的回调形式,这里主要讲一下异步回调形式. Class A实现接 ...
- java异步日志跟同步区别_AJAX中同步和异步的区别和使用场景
AJAX中根据async的值不同分为同步(async = false)和异步(async = true)两种执行方式:在W3C的教程中推荐使用异步执行: 下面来区别一下同步和异步有什么不同: 异步:在 ...
- android 返回字符串,android – 如何从异步回调使用Retrofit返回String或JSONObject?
我想到了.这是尴尬,但它是非常简单-临时解决方案可能是这样的: public void success(Response response, Response ignored) { TypedInpu ...
- java异步处理同步化_java 异步查询转同步多种实现方式:循环等待,CountDownLatch,Spring EventListener,超时处理和空循环性能优化...
异步转同步 业务需求 有些接口查询反馈结果是异步返回的,无法立刻获取查询结果. 正常处理逻辑 触发异步操作,然后传递一个唯一标识. 等到异步结果返回,根据传入的唯一标识,匹配此次结果. 如何转换为同步 ...
- java filter 回调_Java 异步回调机制实例分析
Java 异步回调机制 一.什么是回调 回调,回调.要先有调用,才有调用者和被调用者之间的回调.所以在百度百科中是这样的: 软件模块之间总是存在着一定的接口,从调用方式上,可以把他们分为三类:同步调用 ...
最新文章
- python字符串去掉特殊符号和空格_从字符串中删除所有特殊字符,标点符号和空格...
- helm3添加harbor仓库:带鉴权--username --password
- Pcm设备2M通道,E1的基础知识介绍
- (转)浏览器兼容的JS写法总结
- 这是一项颠覆性技术 - 容器
- 烂泥:centos6.4服务器添加新硬盘
- SQL63 刷题通过的题目排名
- 服务器运行多个jdk版本_如何使用中央管理服务器运行多个查询
- gui卡顿 python_视频下载神器(youget),在 Python 中怎么使用?
- 开课吧:深入了解软件开发原则有哪些?
- vissim4.3安装教程
- 异常检测论文阅读笔记《MIST: Multiple Instance Self-Training Framework for Video Anomaly Detection》
- K8S给节点打标签和打污点
- Lumerical MODE solution FBG光栅透射谱的仿真,官网fbg.lms例子的详解
- 自学java编译老是出错_编写HelloWorld程序编译时提示写入HelloWorld时出错是什么意思...
- iOS:创建Siri 功能
- 解决Retrofit和RxJava 抛出异常报错问题
- Use Configs
- ArcGIS下图像矢量化的基本步骤
- C语言基础知识总结(简单算法套路)