从零并发框架（三）异步转同步注解+字节码增强代理实现
序言上一节我们学习了异步查询转同步的 7 种实现方式 ， 今天我们就来学习一下 ， 如何对其进行封装 ， 使其成为一个更加便于使用的工具 。
思维导图如下：
文章插图
异步转同步字节码增强
拓展阅读java 手写并发框架（一）异步查询转同步的 7 种实现方式
java 手写并发框架（二）异步转同步框架封装锁策略
java 手写并发框架（三）异步转同步框架注解和字节码增强
异步转同步的锁调用同步锁策略
- wait--tt-darkmode-color: #FFFFFF;">实现思路其实整体的实现类似于 spring 的 @Retry 注解 。
（1）在锁同步方法上使用对应的注解 @Sync
（2）在异步回调方法上使用注解 @SyncCallback
（3）通过字节码增强调用方法 ， 拥有上述注解的方法进行对应的加解锁实现
注解的定义同步加锁@Sync 同步注解可以放在希望同步等待的方法上 。
package com.github.houbb.sync.api.annotation;import com.github.houbb.sync.api.constant.LockType;import java.lang.annotation.*;import java.util.concurrent.TimeUnit;/** * 异步转同步注解 * * （1）根据标识匹配结果 * （2）直接简单的返回结果 * * @author binbin.hou * @since 0.0.1 */@Documented@Retention(RetentionPolicy.RUNTIME)@Target(ElementType.METHOD)public @interface Sync {/*** 超时时间** 单位 mills* @return 时间* @since 0.0.1*/long timeout() default 60 * 1000L;/*** 时间单位* @return 时间单位* @since 0.0.1*/TimeUnit timeUnit() default TimeUnit.MILLISECONDS;/*** 等待策略** （1）基于 countDownLatch 等待* （2）基于查询结果等等待** 不同等待策略 ， 结果封装对用户不可见 。* @return 等待* @since 0.0.1*/LockType lock() default LockType.COUNT_DOWN_LATCH;}所有的属性都有默认值 ， 默认为 60s 超时 。
默认的加锁策略是 LockType.COUNT_DOWN_LATCH 。
异步解锁package com.github.houbb.sync.api.annotation;import java.lang.annotation.*;/** * 异步转同步注解 * * （1）根据标识匹配结果 * （2）直接简单的返回结果 * * @author binbin.hou * @since 0.0.1 */@Documented@Retention(RetentionPolicy.RUNTIME)@Target(ElementType.METHOD)public @interface SyncCallback {/*** 对应的方法名称** @return 方法名称* @since 0.0.1*/String value();}这里异步回调解锁只有一个属性 ， 那就是加锁对应的方法名称 。
这里我们不做过多的封装 ， 保证 @Sync 注解的方法名称在当前类唯一即可 ， 这个设计理念和 spring 的 @Retry 是一样的 。
@SyncCallback 可以根据方法名称 ， 找到对应的 @Sync 注解信息 。
核心同步类接口定义package com.github.houbb.sync.api.api;/** * @author binbin.hou * @since 0.0.1 */public interface ISync {/*** 同步* @param context 上下文* @return 方法执行结果* @since 0.0.1* @throws Throwable 异常*/Object sync(final ISyncContext context) throws Throwable;}接口定义非常简单 ， 只有一个方法 ， 通过上下文返回对应的值 。
上下文定义如下：
package com.github.houbb.sync.api.api;import com.github.houbb.sync.api.annotation.Sync;import com.github.houbb.sync.api.annotation.SyncCallback;import java.lang.reflect.Method;/** * sync 上下文 * * @author binbin.hou * @since 0.0.1 */public interface ISyncContext {/*** 同步注解信息* @return 同步注解* @since 0.0.1*/Sync sync();/*** 注解回调* @return 回调* @since 0.0.1*/SyncCallback callback();/*** 参数信息* @return 参数信息* @since 0.0.7*/Object[] params();/*** 方法信息* @return 方法信息* @since 0.0.7*/Method method();/*** 方法执行* @return 执行* @since 0.0.1* @throws Throwable 异常信息*/Object process() throws Throwable;}
推荐阅读
- 青少年|封面评论 |“青少年模式”依旧漏洞百出，标准化合规框架必须落地
- 打造智慧互联新高地——惠阳（良井）智慧互联科技园项目合作框架协议今天签约
- Swagger2—API文档框架（二）
- 在Linux系统中安装深度学习框架Pytorch
- 海外商家试水小程序商城，微盟国际化战略框架已现
- Redis集群做法的难点，百万并发客户端「实战」
- 整理：常见的Java开发框架有哪些，看过，就赶紧收藏吧
- 为什么 Redis 单线程能支撑高并发？
- 并发过程中volatile能否保证线程安全
- Python|TensorFlow 、Caffe等9大主流人工智能框架优劣势分析
![[技时]起售价3999元，小米10系列迎来强敌！一加8系列发布](https://imgcdn.toutiaoyule.com/20200416/20200416204402482498a_t.jpeg)
