实现 Java 异步回调
最编程
2024-07-16 14:18:10
...
说下java的异步回调模式,是指当调用者实现了CallBack接口,调用者包含了被调用者的引用,在调用者类中调用被调用者的方法,然后在被调用者类的方法中调用调用者类的callBack方法。
举个例子,异步体现在A类通过新起的一个线程执行B类的方法,至于该方法有没有执行完,暂时不用去等待。
下面是一个回调代码示例。
类Invoker实现了一个CallBack接口,来计算一个数的平方,在类Invoker中调用了Handler类的方法来计算,Handler通过回调返回计算结果。
先定义一个回调接口,如下:
package com.wpw.springbootjuc.test;
public interface CallBack {
/**
* 一个回调函数
*
* @param object 接收对象
*/
void accept(Object object);
}
然后调用者Invoker实现这个CallBack接口,实现其中的方法。
package com.wpw.springbootjuc.test;
import java.io.Serializable;
/**
* 调用者
* @author wpw
*/
public class Invoker implements CallBack,Serializable{
private Handler handler;
public Invoker(Handler handler){
this.handler=handler;
}
public void invoke(final int num){
new Thread(() -> handler.handlerData(Invoker.this,num)).start();
}
@Override
public void accept(Object object) {
System.out.println(object);
}
}
被调用者Handler处理器进行数据的处理。
package com.wpw.springbootjuc.test;
/**
* 处理器
* @author wpw
*/
public class Handler {
/**
* @param callBack 回调接口
* @param number 接收数据值
* @return 返回值信息
*/
public void handlerData(CallBack callBack, final int number) {
final int count = 1000;
for (int i = 0; i < count; i++) {
}
double v = Math.pow(number, 2);
callBack.accept(v);
}
}
然后写个测试示例程序进行测试,这个程序是不是简单了些。
package com.wpw.springbootjuc.test;
/**
* 测试类
* @author wpw
*/
public class Test {
public static void main(String[] args) {
Handler handler=new Handler();
Invoker invoker=new Invoker(handler);
invoker.invoke(10);
}
}
看下输出结果的信息,如下。
100.0
不过,异步回调作用还是不是很大,后面涉及消息机制知识在说一下它的缺点吧。
推荐阅读
-
深入理解Java回调机制
-
在Java Tomcat中实现中间件的回显功能
-
【2022新手指南】Java编程进阶之路 - 六、技术架构篇 ### MySQL索引底层解析与优化实战 - 你会讲解MySQL索引的数据结构吗?性能调优技巧知多少? - Redis深度揭秘:你知道多少?从基础到哨兵、主从复制全梳理 - Redis持久化及哨兵模式详解,还有集群搭建和Leader选举黑箱打开 - Zookeeper是个啥?特性和应用场景大公开 - ZooKeeper集群搭建攻略及 Leader选举、读写一致性、共享锁实现细节 - 探究ZooKeeper中的Leader选举机制及其在分布式环境中的作用 - Zab协议深入剖析:原理、功能与在Zookeeper中的核心地位 - RabbitMQ全方位解读:工作模式、消费限流、可靠投递与配置策略 - 设计者视角:RabbitMQ过期时间、死信队列与延时队列实践指南 - RocketMQ特性和应用场景揭示:理解其精髓与差异化优势 - Kafka详细介绍:特性及广泛应用于实时数据处理的场景解析 - ElasticSearch实力揭秘:特性概述与作为搜索引擎的广泛应用 - MongoDB认知升级:非关系型数据库的优势阐述,安装与使用实战教学 - BIO/NIO/AIO网络模型对比:掌握它们的区别与在网络编程中的实际应用 - Netty带你飞:理解其超快速度背后的秘密,包括线程模型分析 - 网络通信黑科技:Netty编解码原理与常用编解码器的应用,Protostuff实战演示 - 解密Netty粘包与拆包现象,怎样有效应对这一常见问题 - 自定义Netty心跳检测机制,轻松调整检测间隔时间的艺术 - Dubbo轻骑兵介绍:核心特性概览,服务降级实战与其实现益处 - Dubbo三大神器解读:本地存根与本地伪装的实战运用与优势呈现 ----------------------- 七、结语与回顾
-
深入理解:setTimeout在同步、异步和回调中的执行顺序详解与经典闭包解析
-
如何在Java中使用匿名内部类进行同步回调操作
-
Java 异步编程(5 种异步实现详解)
-
异步调用的 Java 实现
-
Java 实现异步编程的 8 种方法
-
异步回调的 Java 实现
-
Java 实现异步的 8 种方法