Java中的回调
又忙了一周，事情差不多解决了，终于有可以继续写我的博客了（各位看官久等了）。
这次我们来谈一谈Java里的一个很有意思的东西——回调。
什么叫回调，一本正经的来讲，在计算机程序设计中，回调函数是指通过函数参数传递到其它代码的，某一块可执行代码的引用。这一设计允许了底层代码调用在高层定义的子程序。
别急别急，且听我慢慢道来。
举个栗子，设置这样一个情景，老板安排员工做事，然后让他做完后跟他电话说一声。老板当然不会在那里一直等员工做完事情才去做其他事，而是只交代完任务就去忙自己的事情了。
这个例子包含了异步+回调的思想，员工做完任务后向老板报告这个过程，就叫回调，当然，报告的话，老板肯定先跟员工说好了报告方式，比如说邮件，电话等，而交代报告方式，就是注册回调函数，这里的回调函数必须符合接口的规范。
好像还是有些不明白？来上代码吧。
先定义一个接口：.
publicinterfaceReceiveReport{
/**
*接收报告
*@paramname员工名称
*@paramreport报告内容
*/
publicvoidreceiveReport(Stringname,Stringreport);
}
定义一个Boss类实现这个接收报告的接口：
publicclassBossimplementsReceiveReport{
privateWorkerworker;
publicBoss(Workerworker){
this.worker=worker;
}
/**
*下达任务
*/
publicvoidsendTask(){
worker.work(this);
}
/**
*接收报告
*@paramname员工名称
*@paramreport报告内容
*/
publicvoidreceiveReport(Stringname,Stringreport){
System.out.println("收到："+name+"的报告："+report);
}
}
定义一个Worker接口：
publicinterfaceWorker{
publicvoidwork(ReceiveReportboss);
}
定义一个员工类。
publicclassEmployeeimplementsWorker{
privateStringname;//员工姓名
//构造器
publicEmployee(Stringname){
this.name=name;
}
/**
*工作
*@paramboss任务名称
*/
publicvoidwork(ReceiveReportboss){
System.out.println(name+"isdoingworks.");
Stringreport="我已经完成了任务！";
boss.receiveReport(name,report);
}
}
然后来测试一下：
publicclassTest{
publicstaticvoidmain(String[]args){
Workeremployee=newEmployee("Frank");//定义一个员工
Bossboss=newBoss(employee);//定义一个Boss
//boss开始下达任务
boss.sendTask();
}
}
测试结果：
Frankisdoingworks.收到：Frank的报告：我已经完成了任务！
至此，员工与老板的交互就完成了，这就是一个简单的同步回调了。Boss通过Worker接口可以给员工安排工作，而不用去关心是哪个员工在工作，Worker通过ReceiveReport来向Boss报告工作情况，两个类通过接口进行回调交互，可以很好的解耦合，因为Boss可以安排不同的员工，只要他们实现了Worker接口就行，而员工也可以向不同的boss汇报情况，只要实现了ReceiveReport接口即可。
其实回调的核心思想就是把自身的this指针传给调用方，就像这里把employee传入Boss类中，在work方法中又注册了回调，于是两者的交互性就很强了。
那么为什么要用回调呢？如果Boss要在员工完成工作之前登记员工的一些信息，如姓名等，那么有了回调机制，通过把this指针传入，就能在Boss内部为所欲为了，而不需要通过设计新的方法来获取，而且需要获得的数据越多，回调的优势越明显。
其实这里只是简单的一对一关系，如果是一个Boss，多个员工，那就是简单的观察者模式，如果是多个Boss多个员工，那就是简单生产者-消费者模式了。
当然，这里仅仅是简单的同步回调。员工只能一个接一个的去完成任务，也就是说前一个员工必须等待后一个员工完成任务后才能开始任务，事实上，员工一般是同时进行工作的。
如果换一个场景，现在有十个员工，老板发布任务，前三名完成的人有奖金奖励，那么就需要用到异步回调了，sendTask的时候使用线程即可，我们来修改一下代码：
/**
*@authorFrank
*@create2017/12/3
*@description接收报告接口
*/
publicinterfaceReceiveReport{
/**
*接收报告
*@paramworker员工
*@paramreport报告内容
*/
publicvoidreceiveReport(Workerworker,Stringreport);
}
/**
*@authorFrank
*@create2017/12/3
*@description工人接口
*/
publicinterfaceWorker{
publicvoidwork(StringtaskName);
publicvoidsetReceiveReport(ReceiveReportboss);
publicvoidgetReward(Doublemoney);
publicStringgetName();
}
importjava.util.Random;
/**
*@authorFrank
*@create2017/12/3
*@description员工类
*/
publicclassEmployeeimplementsWorker{
privateReceiveReportboss;
privateStringname;//员工姓名
@Override
publicStringgetName(){
returnname;
}
//构造器
publicEmployee(Stringname){
this.name=name;
}
publicvoidsetReceiveReport(ReceiveReportboss){
this.boss=boss;
}
@Override
publicvoidgetReward(Doublemoney){
System.out.println(name+"由于表现突出，获得$"+money+"现金奖励！");
}
/**
*工作
*@paramtaskName任务名称
*/
publicvoidwork(StringtaskName){
System.out.println(name+"isdoingworks:"+taskName);
Randomrandom=newRandom();
Integertime=random.nextInt(10000);
try{
Thread.sleep(time);
}catch(InterruptedExceptione){
e.printStackTrace();
}
Stringreport="顺利完成任务！";
//通知老板
boss.receiveReport(this,report);
}
}
importjava.util.ArrayList;
importjava.util.List;
/**
*@authorFrank
*@create2017/12/3
*@descriptionBoss类
*/
publicclassBossimplementsReceiveReport{
privateListworkers=newArrayList<>();//老板管理的员工
privatevolatileintindex;//顺序
/**
*添加员工
*@paramworker员工
*/
publicvoidaddWorker(Workerworker){
workers.add(worker);
worker.setReceiveReport(this);
}
/**
*下达任务
*/
publicvoidsendTask(Stringtask){
//给各个员工依次下达任务
for(Workerw:workers){
newThread(newRunnable(){
@Override
publicvoidrun(){
w.work(task);
}
}).start();
}
}
/**
*接收报告
*@paramworker员工
*@paramreport报告内容
*/
publicvoidreceiveReport(Workerworker,Stringreport){
intindex=++this.index;
System.out.println(worker.getName()+"获得第"+index+"名");
if(index<=3){
//给前三名发奖金
worker.getReward(1000.0*(4-index));
}
}
}
/**
*@authorFrank
*@create2017/12/3
*@description
*/
publicclassTest{
publicstaticvoidmain(String[]args){
Bossboss=newBoss();//定义一个Boss
//定义十个员工
for(inti=0;i<10;i++){
Workerworker=newEmployee("Employee["+i+"]");
boss.addWorker(worker);
}
//boss开始下达任务
boss.sendTask("SayHello");
}
}
这里没有使用锁，因为设置的时间间隔区间为0-10s，发生并发冲突的概率很低，而且由于现在还没有说多线程的内容，所以暂时先不使用。只需要知道在sendTask方法中，依次启动了线程来调用每个Worker的work方法，线程启动后会同时执行，执行完毕后，又会调用Boss的receiveReport方法来向Boss反馈结果，接收结果后，根据完成顺序，再调用Worker的getReward方法来给前三名发奖金。其实这里是双向回调了，Boss把this指针传给了Worker，Worker又把自己的this指针传给了Worker。
程序执行结果如下：
Employee[0]isdoingworks:SayHello
Employee[4]isdoingworks:SayHello
Employee[3]isdoingworks:SayHello
Employee[2]isdoingworks:SayHello
Employee[1]isdoingworks:SayHello
Employee[5]isdoingworks:SayHello
Employee[7]isdoingworks:SayHello
Employee[6]isdoingworks:SayHello
Employee[9]isdoingworks:SayHello
Employee[8]isdoingworks:SayHello
Employee[9]获得第1名
Employee[9]由于表现突出，获得$3000.0现金奖励！
Employee[7]获得第2名
Employee[7]由于表现突出，获得$2000.0现金奖励！
Employee[3]获得第3名
Employee[3]由于表现突出，获得$1000.0现金奖励！
Employee[1]获得第4名
Employee[0]获得第5名
Employee[5]获得第6名
Employee[4]获得第7名
Employee[8]获得第8名
Employee[6]获得第9名
Employee[2]获得第10名
因为使用了多线程，所以每次运行的结果可能都会不一样，如果得到了不一样的结果，那是很正常的现象。
举了这两个栗子，对回调应该也有了一定的了解了吧。
其实回调只是一种思想，并不是java中独有的内容，思想这种东西，是为了解决特定场景下的特定问题而出现的，只有被正确应用了才有它的价值，而不要为了使用它而使用它。
至此，回调讲解完毕，如有说明有误的地方，欢迎各位批评指正。也欢迎大家继续关注。
以上就是Java中的回调的详细内容，更多关于Java回调的资料请关注毛票票其它相关文章！
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。