实现java的异步回调
说下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不过，异步回调作用还是不是很大，后面涉及消息机制知识在说一下它的缺点吧。
本文参与 腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2020-04-04，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读