Java回调机制解读

模块间调用

在一个应用系统中,无论使用何种语言开发,必然存在模块之间的调用,调用的方式分为几种:

(1)同步调用

同步调用是最基本并且最简单的一种调用方式,类A的方法a()调用类B的方法b(),一直等待b()方法执行完毕,a()方法继续往下走。这种调用方式适用于方法b()执行时间不长的情况,因为b()方法执行时间一长或者直接阻塞的话,a()方法的余下代码是无法执行下去的,这样会造成整个流程的阻塞。

(2)异步调用

异步调用是为了解决同步调用可能出现阻塞,导致整个流程卡住而产生的一种调用方式。类A的方法方法a()通过新起线程的方式调用类B的方法b(),代码接着直接往下执行,这样无论方法b()执行时间多久,都不会阻塞住方法a()的执行。但是这种方式,由于方法a()不等待方法b()的执行完成,在方法a()需要方法b()执行结果的情况下(视具体业务而定,有些业务比如启异步线程发个微信通知、刷新一个缓存这种就没必要),必须通过一定的方式对方法b()的执行结果进行监听。在Java中,可以使用Future+Callable的方式做到这一点,具体做法可以参见我的这篇文章Java多线程21:多线程下其他组件之CyclicBarrier、Callable、Future和FutureTask。

(3)回调

 

最后是回调,回调的思想是:

  • 类A的a()方法调用类B的b()方法
  • 类B的b()方法执行完毕主动调用类A的callback()方法

这样一种调用方式组成了上图,也就是一种双向的调用方式。

 

代码示例

接下来看一下回调的代码示例,代码模拟的是这样一种场景:老师问学生问题,学生思考完毕回答老师。

首先定义一个回调接口,只有一个方法tellAnswer(int answer),即学生思考完毕告诉老师答案:

1 /**
2  * 回调接口,原文出处http://www.cnblogs.com/xrq730/p/6424471.html
3  */
4 public interface Callback {
5 
6     public void tellAnswer(int answer);
7     
8 }

定义一个老师对象,实现Callback接口:

 1 /**
 2  * 老师对象,原文出处http://www.cnblogs.com/xrq730/p/6424471.html
 3  */
 4 public class Teacher implements Callback {
 5 
 6     private Student student;
 7     
 8     public Teacher(Student student) {
 9         this.student = student;
10     }
11     
12     public void askQuestion() {
13         student.resolveQuestion(this);
14     }
15     
16     @Override
17     public void tellAnswer(int answer) {
18         System.out.println("知道了,你的答案是" + answer);
19     }
20     
21 }

老师对象有两个public方法:

(1)回调接口tellAnswer(int answer),即学生回答完毕问题之后,老师要做的事情

(2)问问题方法askQuestion(),即向学生问问题

接着定义一个学生接口,学生当然是解决问题,但是接收一个Callback参数,这样学生就知道解决完毕问题向谁报告:

1 /**
2  * 学生接口,原文出处http://www.cnblogs.com/xrq730/p/6424471.html
3  */
4 public interface Student {
5     
6     public void resolveQuestion(Callback callback);
7     
8 }

最后定义一个具体的学生叫Ricky:

 1 /**
 2  * 一个名叫Ricky的同学解决老师提出的问题,原文出处http://www.cnblogs.com/xrq730/p/6424471.html
 3  */
 4 public class Ricky implements Student {
 5 
 6     @Override
 7     public void resolveQuestion(Callback callback) {
 8         // 模拟解决问题
 9         try {
10             Thread.sleep(3000);
11         } catch (InterruptedException e) {
12             
13         }
14         
15         // 回调,告诉老师作业写了多久
16         callback.tellAnswer(3);
17     }
18 
19 }

在解决完毕问题之后,第16行向老师报告答案。

写一个测试类,比较简单:

 1 /**
 2  * 回调测试,原文出处http://www.cnblogs.com/xrq730/p/6424471.html
 3  */
 4 public class CallbackTest {
 5 
 6     @Test
 7     public void testCallback() {
 8         Student student = new Ricky();
 9         Teacher teacher = new Teacher(student);
10         
11         teacher.askQuestion();
12         
13     }
14     
15 }

代码运行结果就一行:

知道了,你的答案是3

简单总结、分析一下这个例子就是:

(1)老师调用学生接口的方法resolveQuestion,向学生提问

(2)学生解决完毕问题之后调用老师的回调方法tellAnswer

这样一套流程,构成了一种双向调用的关系。

 

代码分析

分析一下上面的代码,上面的代码我这里做了两层的抽象:

(1)将老师进行抽象

  • 将老师进行抽象之后,对于学生来说,就不需要关心到底是哪位老师询问我问题,只要我根据询问的问题,得出答案,然后告诉提问的老师就可以了,即使老师换了一茬又一茬,对我学生而言都是没有任何影响的

(2)将学生进行抽象

  • 将学生进行抽象之后,对于老师这边来说就非常灵活,因为老师未必对一个学生进行提问,可能同时对Ricky、Jack、Lucy三个学生进行提问,这样就可以将成员变量Student改为List<Student>,这样在提问的时候遍历Student列表进行提问,然后得到每个学生的回答即可

这个例子是一个典型的体现接口作用的例子,之所以这么说是因为我想到有些朋友可能不太明白接口的好处,不太明白接口好处的朋友可以重点看一下这个例子,多多理解。

总结起来,回调的核心就是回调方将本身即this传递给调用方,这样调用方就可以在调用完毕之后告诉回调方它想要知道的信息。回调是一种思想、是一种机制,至于具体如何实现,如何通过代码将回调实现得优雅、实现得可扩展性比较高,一看开发者的个人水平,二看开发者对业务的理解程度。

 

同步回调与异步回调

上面的例子,可能有人会提出这样的疑问:

这个例子需要用什么回调啊,使用同步调用的方式,学生对象回答完毕问题之后直接把回答的答案返回给老师对象不就好了?

这个问题的提出没有任何问题,可以从两个角度去理解这个问题。

首先,老师不仅仅想要得到学生的答案怎么办?可能这个老师是个更喜欢听学生解题思路的老师,在得到学生的答案之前,老师更想先知道学生姓名和学生的解题思路,当然有些人可以说,那我可以定义一个对象,里面加上学生的姓名和解题思路不就好了。这个说法在我看来有两个问题:

(1)如果老师想要的数据越来越多,那么返回的对象得越来越大,而使用回调则可以进行数据分离,将一批数据放在回调方法中进行处理,至于哪些数据依具体业务而定,如果需要增加返回参数,直接在回调方法中增加即可

(2)无法解决老师希望得到学生姓名、学生解题思路先于学生回答的答案的问题

因此我认为简单的返回某个结果确实没有必要使用回调而可以直接使用同步调用,但是如果有多种数据需要处理且数据有主次之分,使用回调会是一种更加合适的选择,优先处理的数据放在回调方法中先处理掉。

另外一个理解的角度则更加重要,就是标题说的同步回调和异步回调了。例子是一个同步回调的例子,意思是老师向Ricky问问题,Ricky给出答案,老师问下一个同学,得到答案之后继续问下一个同学,这是一种正常的场景,但是如果我把场景改一下:

老师并不想One-By-One这样提问,而是同时向Ricky、Mike、Lucy、Bruce、Kate五位同学提问,让同学们自己思考,哪位同学思考好了就直接告诉老师答案即可。

这种场景相当于是说,同学思考完毕完毕问题要有一个办法告诉老师,有两个解决方案:

(1)使用Future+Callable的方式,等待异步线程执行结果,这相当于就是同步调用的一种变种,因为其本质还是方法返回一个结果,即学生的回答

(2)使用异步回调,同学回答完毕问题,调用回调接口方法告诉老师答案即可。由于老师对象被抽象成了Callback接口,因此这种做法的扩展性非常好,就像之前说的,即使老师换了换了一茬又一茬,对于同学来说,只关心的是调用Callback接口回传必要的信息即可

 

转载于:https://www.cnblogs.com/xrq730/p/6424471.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/356106.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Java TDD简介–第1部分

欢迎来到测试驱动开发 &#xff08;TDD&#xff09;系列的介绍。 我们将在TDD上下文中讨论Java和JUnit &#xff0c;但这只是工具。 本文的主要目的是使您全面了解TDD&#xff0c;而无论使用哪种编程语言和测试框架。 如果您在项目中不使用TDD&#xff0c;那么您要么很懒&…

HDU 2629 Identity Card

简单题 给出身份证号 判断住址 和出生年月 熟练字符串的操作 主要是string::substr(s, l)//s:起始位置 l长度 1 #include <iostream>2 #include <stdio.h>3 #include <string>4 #include <string.h>5 #include <map>6 #include <fstream>…

状态模式 处理订单状态_将状态机模式实现为流处理器

状态模式 处理订单状态在我的上一个博客中&#xff0c;我说过我真的以为某些“四人行”&#xff08;GOF&#xff09;模式已经过时了&#xff0c;如果不是过时的话肯定不受欢迎。 特别是我说过StateMachine没什么用&#xff0c;因为您通常会想到另一种更简单的方式来执行您正在执…

mysql 连续签到天数_最大连续签到天数-sql

SELECT MIN(rq) as 起始日期, MAX(rq) as 终止日期, MAX(id1) - MIN(id1) 1 as 持续天数,id3 as 累计签到天数,nameFROM (SELECT datediff(rq,2020-02-01 )id1, (SELECT COUNT(1)FROM tmptableWHERE rq < a.rq andtype 是) id2,(SELECT COUNT(1)FROM tmptableWHEREtype 是…

具有代理设置的Spring Cloud AWS

在我的上一篇文章Spring和Amazon Web Services中 &#xff0c;我简要介绍了Spring Cloud AWS模块以及开发人员现在对它的期望。 从官方文档中看不出来的一件事是&#xff0c;当您的Internet连接受到代理服务器的限制时&#xff0c;如何使用此模块。 在本文中&#xff0c;我将概…

mysql两者之间_Django和MySQL - 两者之间的数据是不同的

我有一个使用MySQL作为后端的Django应用程序。我在原始MySQL记录显示一个值时遇到困难&#xff0c;但Django在Web应用程序中提供了其他内容。例如&#xff0c;我有一个客户端数据表。每条记录中的一个字段称为snailMailInvoice并且是Y / N选项 - 默认值是Y(varchar类型)。-----…

hdoj 4272 LianLianKan 数据太水

点击打开链接 题意&#xff1a; 给出一个序列&#xff0c;其中距离不超过6的两个相同的数字可以消除掉&#xff08;从上往下消&#xff0c;输入是从底向上的&#xff09;&#xff0c;问能不能全部消除。 思路&#xff1a; 状压dp http://www.cnblogs.com/swm8023/archive/2012/…

mysql 两个查询结果合并去重_《MySQL 入门教程》第 21 篇 集合操作符

文章来源&#xff1a;https://blog.csdn.net/horses/article/details/108174837来源平台&#xff1a;CSDN原文作者&#xff1a;不剪发的Tony老师数据表与集合理论中的集合非常类似&#xff0c;表是由行组成的集合。SQL 标准定义了基于行的各种集合操作&#xff1a;并集运算(UNI…

binutils工具集之---ar

1.如果要将多个.o文件生成一个库文件&#xff0c;则存在两种类型的库&#xff0c;一种是静态库&#xff0c;在linux里面后缀是.a&#xff0c;另一种是动态库&#xff0c;后缀为.so。 当可执行程序要与静态库进行链接时&#xff0c;所用到的库中的函数和数据会被拷贝到最终的可执…

jax-rs jax-ws_Google App Engine JAX-RS REST服务

jax-rs jax-ws在本文中&#xff0c;您将学习如何使用JAX-RS参考实现&#xff08;Jersey&#xff09;创建REST服务并将其部署在Google AppEngine上。 先决条件 对于本教程&#xff0c;您将需要&#xff1a; 一个Google AppEngine帐户 Eclipse Galileo&#xff08;3.5.x&#xf…

mysql锁与性能_MySQL性能优化--锁(概念)

《 MySQL性能优化&#xff0d;&#xff0d;锁》首发牧码人博客转发请加此提示MySQL基本概念&#xff0d;&#xff0d;锁介绍下对于MySQL锁机制的理解从基本概念开始&#xff1a;共享锁共享锁的代号是S&#xff0c;是Share的缩写&#xff0c;共享锁的锁粒度是行或者元组(多个行)…

[转]使用C#开发ActiveX控件

前言 ActiveX控件以前也叫做OLE控件&#xff0c;它是微软IE支持的一种软件组件或对象&#xff0c;可以将其插入到Web页面中&#xff0c;实现在浏览器端执行动态程序功能&#xff0c;以增强浏览器端的动态处理能力。通常ActiveX控件都是用C或VB语言开发&#xff0c;本文介绍另一…

用Java测试多线程代码

测试多线程代码是一个艰巨的挑战。 尝试测试并发性时获得的第一个建议是尽可能地在代码中隔离并发问题。 这是一般的设计建议&#xff0c;但在这种情况下甚至更重要。 确保首先正确地对并发构造所包装的逻辑进行单元测试。 否则&#xff0c;您可能会花费很长时间尝试找出一个并…

php pdo mysql query_PHP+MYSQL中使用PDO的query方法

一 代码class"php">PDO连接MySQL数据库IDPDO数据库时间$dbmsmysql; //数据库类型 ,对于开发者来说&#xff0c;使用不同的数据库&#xff0c;只要改这个&#xff0c;不用记住那么多的函数$hostlocalhost; //数据库主机名$dbNamedb_database15; //使用的数据库$use…

pat 团体赛练习题集 L2-008. 最长对称子串

对给定的字符串&#xff0c;本题要求你输出最长对称子串的长度。例如&#xff0c;给定"Is PAT&TAP symmetric?"&#xff0c;最长对称子串为"s PAT&TAP s"&#xff0c;于是你应该输出11。 输入格式&#xff1a; 输入在一行中给出长度不超过1000的…

在Apache Camel中使用Spring数据

Spring Data通过创建智能的DAO节省了很多时间&#xff0c;您基本上不需要编写任何代码就可以免费获得DAO。 它基本上遵循Eric Evans的DDD书中的“ 存储库模式 ” &#xff0c;并将实体视为集合。 它有一个很好的约定&#xff0c;允许您为复杂查询指定条件&#xff0c;甚至可以将…

python协程池操作mysql_python_协程方式操作数据库

#!/usr/bin/python3# -*- coding: utf-8 -*-import requestsimport geventimport pymysqlfrom gevent import monkey# 堵塞标记monkey.patch_all()class SqlSave(object):"""协程方式写入数据库"""def __init__(self):SQL_DBA {‘host‘: ‘loc…

bootstrap在ie8下,兼容媒体查询

最近使用bootstrap做网站的时候发现&#xff0c;在ie8下的媒体查询一直失效&#xff1a; 后来解决了&#xff0c;做如下记录&#xff1a; 1、必须运行在服务器下 2、hack 条件语法&#xff0c;如下&#xff1a; <!--[if lte ie 9]><script src"js/html5shiv.min.…

java 冒号 正则表达式_Java正则表达式问号冒号的使用

在Java和Javascript中正则表达式字符串前面加上?:表示非捕获型匹配&#xff0c;否则就是捕获型匹配。捕获型括号会将匹配到的内容捕获到一些变量里&#xff0c;这些变量按照捕获型括号的左括号为顺序从1开始编号。为了避免括号太多使编号混乱&#xff0c;也为了避免无用的捕获…

Hibernate中的一对多XML映射

一对多关系指出一个实体的单个实例与另一个实体的多个实例相关联。 换句话说&#xff0c;一个表中的每个记录与另一个表中的多个记录相关联。 让我们看看如何通过XML映射文件在Hibernate中定义这种关系。 1.实体关系图 假设我们已经在数据库中创建了学生表和部门表&#xff0…