Java基础9:解读Java回调机制

Java基础9:解读Java回调机制

模块间的调用

本部分摘自https://www.cnblogs.com/xrq730/p/6424471.html

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

(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()方法 这样一种调用方式组成了上图,也就是一种双向的调用方式。

回调实例:Tom做题

数学老师让Tom做一道题,并且Tom做题期间数学老师不用盯着Tom,而是在玩手机,等Tom把题目做完后再把答案告诉老师。

1 数学老师需要Tom的一个引用,然后才能将题目发给Tom。

2 数学老师需要提供一个方法以便Tom做完题目以后能够将答案告诉他。

3 Tom需要数学老师的一个引用,以便Tom把答案给这位老师,而不是隔壁的体育老师。

回调接口,可以理解为老师接口

//回调指的是A调用B来做一件事,B做完以后将结果告诉给A,这期间A可以做别的事情。//这个接口中有一个方法,意为B做完题目后告诉A时使用的方法。//所以我们必须提供这个接口以便让B来回调。//回调接口,public interface CallBack {    void tellAnswer(int res);}

数学老师类

    //老师类实例化回调接口,即学生写完题目之后通过老师的提供的方法进行回调。    //那么学生如何调用到老师的方法呢,只要在学生类的方法中传入老师的引用即可。    //而老师需要指定学生答题,所以也要传入学生的实例。public class Teacher implements CallBack{    private Student student;?    Teacher(Student student) {        this.student = student;    }?    void askProblem (Student student, Teacher teacher) {        //main方法是主线程运行,为了实现异步回调,这里开启一个线程来操作        new Thread(new Runnable() {            @Override            public void run() {                student.resolveProblem(teacher);            }        }).start();        //老师让学生做题以后,等待学生回答的这段时间,可以做别的事,比如玩手机.\        //而不需要同步等待,这就是回调的好处。        //当然你可以说开启一个线程让学生做题就行了,但是这样无法让学生通知老师。        //需要另外的机制去实现通知过程。        // 当然,多线程中的future和callable也可以实现数据获取的功能。        for (int i = 1;i < 4;i ++) {            System.out.println("等学生回答问题的时候老师玩了 " + i + "秒的手机");        }    }?    @Override    public void tellAnswer(int res) {        System.out.println("the answer is " + res);    }}

学生接口

    //学生的接口,解决问题的方法中要传入老师的引用,否则无法完成对具体实例的回调。    //写为接口的好处就是,很多个学生都可以实现这个接口,并且老师在提问题时可以通过    //传入List<Student>来聚合学生,十分方便。public interface Student {    void resolveProblem (Teacher teacher);}

学生Tom

public class Tom implements Student{?    @Override    public void resolveProblem(Teacher teacher) {        try {            //学生思考了3秒后得到了答案,通过老师提供的回调方法告诉老师。            Thread.sleep(3000);            System.out.println("work out");            teacher.tellAnswer(111);        } catch (InterruptedException e) {            e.printStackTrace();        }    }

测试类

public class Test {    public static void main(String[] args) {        //测试        Student tom = new Tom();        Teacher lee = new Teacher(tom);        lee.askProblem(tom, lee);        //结果//        等学生回答问题的时候老师玩了 1秒的手机//        等学生回答问题的时候老师玩了 2秒的手机//        等学生回答问题的时候老师玩了 3秒的手机//        work out//        the answer is 111    }}

多线程中的“回调”

Java多线程中可以通过callable和future或futuretask结合来获取线程执行后的返回值。实现方法是通过get方法来调用callable的call方法获取返回值。

其实这种方法本质上不是回调,回调要求的是任务完成以后被调用者主动回调调用者的接口。而这里是调用者主动使用get方法阻塞获取返回值。

public class 多线程中的回调 {    //这里简单地使用future和callable实现了线程执行完后    public static void main(String[] args) throws ExecutionException, InterruptedException {        ExecutorService executor = Executors.newCachedThreadPool();        Future<String> future = executor.submit(new Callable<String>() {            @Override            public String call() throws Exception {                System.out.println("call");                TimeUnit.SECONDS.sleep(1);                return "str";            }        });        //手动阻塞调用get通过call方法获得返回值。        System.out.println(future.get());        //需要手动关闭,不然线程池的线程会继续执行。        executor.shutdown();?    //使用futuretask同时作为线程执行单元和数据请求单元。    FutureTask<Integer> futureTask = new FutureTask(new Callable<Integer>() {        @Override        public Integer call() throws Exception {            System.out.println("dasds");            return new Random().nextInt();        }    });    new Thread(futureTask).start();    //阻塞获取返回值    System.out.println(futureTask.get());}@Testpublic void test () {    Callable callable = new Callable() {        @Override        public Object call() throws Exception {            return null;        }    };    FutureTask futureTask = new FutureTask(callable);?}}

原文地址:https://www.cnblogs.com/itxiaok/p/10356505.html

时间: 2024-11-06 06:08:33

Java基础9:解读Java回调机制的相关文章

Java基础知识——类装载器与反射机制

类装载器ClassLoader 类装载器就是寻找类的字节码文件,并构造出类在JVM内部表示的对象组件. 类装载器把一个类装入JVM中,要经过三步: 1.装载:查找和导入Class文件: 2.链接:执行校验.准备和解析(解析是可以选择的): 3.初始化:对类的静态变量.静态代码块执行初始化工作: 类装载工作由ClassLoader及其子类负责.JVM在运行时会产生三个ClassLoader:根装载器.ExtClassLoader(扩展类装载器)和AppClassLoader(系统类装载器). 根装

Java基础学习总结——Java对象的序列化和反序列化

一.序列化和反序列化的概念 把对象转换为字节序列的过程称为对象的序列化. 把字节序列恢复为对象的过程称为对象的反序列化. 对象的序列化主要有两种用途: 1) 把对象的字节序列永久地保存到硬盘上,通常存放在一个文件中: 2) 在网络上传送对象的字节序列. 在很多应用中,需要对某些对象进行序列化,让它们离开内存空间,入住物理硬盘,以便长期保存.比如最常见的是Web服务器中的Session对象,当有 10万用户并发访问,就有可能出现10万个Session对象,内存可能吃不消,于是Web容器就会把一些s

Java基础11:Java泛型详解

Java基础11:Java泛型详解 泛型概述 泛型在java中有很重要的地位,在面向对象编程及各种设计模式中有非常广泛的应用. 什么是泛型?为什么要使用泛型? 泛型,即"参数化类型".一提到参数,最熟悉的就是定义方法时有形参,然后调用此方法时传递实参.那么参数化类型怎么理解呢?顾名思义,就是将类型由原来的具体的类型参数化,类似于方法中的变量参数,此时类型也定义成参数形式(可以称之为类型形参),然后在使用/调用时传入具体的类型(类型实参). 泛型的本质是为了参数化类型(在不创建新的类型的

Java基础17:Java IO流总结

Java基础17:Java IO流总结 IO流概述 在这一小节,我会试着给出Java IO(java.io)包下所有类的概述.更具体地说,我会根据类的用途对类进行分组.这个分组将会使你在未来的工作中,进行类的用途判定时,或者是为某个特定用途选择类时变得更加容易. 输入和输出 术语"输入"和"输出"有时候会有一点让人疑惑.一个应用程序的输入往往是另外一个应用程序的输出?那么OutputStream流到底是一个输出到目的地的流呢,还是一个产生输出的流?InputStre

Java基础16:Java多线程基础最全总结

Java基础16:Java多线程基础最全总结 Java中的线程 Java之父对线程的定义是: 线程是一个独立执行的调用序列,同一个进程的线程在同一时刻共享一些系统资源(比如文件句柄等)也能访问同一个进程所创建的对象资源(内存资源).java.lang.Thread对象负责统计和控制这种行为. 每个程序都至少拥有一个线程-即作为Java虚拟机(JVM)启动参数运行在主类main方法的线程.在Java虚拟机初始化过程中也可能启动其他的后台线程.这种线程的数目和种类因JVM的实现而异.然而所有用户级线

转载:java基础学习总结——java读取properties文件总结

java基础学习总结--java读取properties文件总结 一.java读取properties文件总结 在java项目中,操作properties文件是经常要做的,因为很多的配置信息都会写在properties文件中,这里主要是总结使用getResourceAsStream方法和InputStream流去读取properties文件,使用getResourceAsStream方法去读取properties文件时需要特别注意properties文件路径的写法,测试项目如下: 1.1.项目的

java基础学习总结——java环境变量配置(转)

java基础学习总结——java环境变量配置 前言 学习java的第一步就要搭建java的学习环境,首先是要安装 JDK,JDK安装好之后,还需要在电脑上配置"JAVA_HOME”."path”."classpath"这三个环境变量才能够把java的开发环境 搭建好.在没安装过jdk的环境下,path环境变量是系统变量,本来存在的,而JAVA_HOME和classpath是不存在的. 一.配置JAVA_HOME变量 操作步骤(win7系统):计算机→右键“属性”→高

java基础知识《JAVA 核心技术》学习笔记(一)

一:数据类型 (1)java整形: 类型                         存储要求 int                              4字节 short                          2字节 long                           8字节 byte                           1字节 (2)浮点类型 类型                         储存要求 float            

Java基础19:Java集合框架梳理

Java基础19:Java集合框架梳理 在编写java程序中,我们最常用的除了八种基本数据类型,String对象外还有一个集合类,在我们的的程序中到处充斥着集合类的身影! java中集合大家族的成员实在是太丰富了,有常用的ArrayList.HashMap.HashSet,也有不常用的Stack.Queue,有线程安全的Vector.HashTable,也有线程不安全的LinkedList.TreeMap等等! 上面的图展示了整个集合大家族的成员以及他们之间的关系.下面就上面的各个接口.基类做一

java基础之--反射机制

反射的概念: 反射是指程序可以访问.检测和修改它本身的状态和形为的一种能力,并根据自身形为的状态和结果,调整和修改程序所描述的形为的状态和相关语义.                反射是java中一强大的工具,能够使我们很方便的创建灵活的代码,这些代码可以在运行时装配,无须在组件之间进行源码链接.但反射使用不当会使成本很高. 反射的作用: 反编译:.class-->.java 通过反射机制访问java对象的属性,方法,构造方法等: sun为我们提供的反射机制的类: java.lang.Class