Java回调机制CallBack总结(生产者消费者模式、监听者模式)

谁践踏了优雅 2021-11-01 12:26 442阅读 0赞

## 什么是回调 ##

在A类中定义了一个方法，这个方法中用到了一个接口和该接口中的抽象方法，但是抽象方法没有具体的实现，需要B类去实现，B类实现该方法后，它本身不会去调用该方法，而是传递给A类，供A类去调用，这种机制就称为回调。

--------------------

# 生产者消费者模式 #

## 一个例子 ##

一个销售向工人订了100台机器准备卖给老外,让工人在生产完100台机器后通知下他.

## Worker ##

package Solution;
    
    public class Worker { 
        private WorkerListner workerListner;
    
        public void MakeMachine(){ 
            int num = 0;
            num = 100;
            //生产100个之后，回调
            workerListner.onWorkerListner(num);
        }
    
        public interface WorkerListner { 
            //回调接口，销售的操作需要实现这个接口
            void onWorkerListner(int num);
        }
    
        public void setWorkerListner(WorkerListner workerListner) { 
            this.workerListner = workerListner;
        }
    }

## Seller ##

package Solution;
    
    
    public class Seller { 
        private static Worker worker = new Worker();
    
        private static void sell() { 
            System.out.println("开始销售机器");
        }
    
        public static void main(String[] args) { 
            //实现回调接口，将售卖方法放在回调接口里面
            worker.setWorkerListner(num -> { 
                System.out.println("现在已经生产完成" + num + "台机器");
                sell();
            });
    
            worker.MakeMachine();
        }
    
    }

![在这里插入图片描述][20190811214319571.png]

*  生产者在生产100台机器之后，调用回调接口通知消费者消费
 *  消费者实现这个回调接口，生产者生产完毕调用接口之后，消费者开始消费。

## 总结 ##

*  接口: 哪里需要被监听,接口就写在那里.
 *  引用: 要有引用才可以对被监听者进行设置监听.
 *  实现: 哪里需要数据/结果,就在那里进行实现

在上面这个需求里面：

*  哪里需要被监听 -> 工人 (监听工人工作进度)
 *  哪里需要结果 -> 销售 (得到工人生产的结果)
 *  对被监听者进行设置监听 -> 销售 (因为结果最终在销售类里获得,因此设置监听要在这里)

--------------------

# 监听者模式 #

## 一个例子 ##

worker每生产一个，就告诉seller，知道生产一百个之后，seller进行销售

## Worker ##

package Solution;
    
    public class Worker { 
        private WorkerListner workerListner;
    
        public void MakeMachine(){ 
            for(int num = 0; num <= 100; num ++) { 
                //调用接口通知监听者
                workerListner.onWorkerListner(num);
            }
        }
    
        public interface WorkerListner { 
            //回调接口，销售的操作需要实现这个接口
            void onWorkerListner(int num);
        }
    
        public void setWorkerListner(WorkerListner workerListner) { 
            this.workerListner = workerListner;
        }
    }

## Seller ##

package Solution;
    
    
    public class Seller { 
        private static Worker worker = new Worker();
    
        private static void sell() { 
            System.out.println("开始销售机器");
        }
    
        public static void main(String[] args) { 
            //实现回调接口，将售卖方法放在回调接口里面
            worker.setWorkerListner(num -> { 
                System.out.println("现在已经生产完成" + num + "台机器");
                if(num == 100) { 
                    sell();
                }
            });
    
            worker.MakeMachine();
        }
    
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zNjM3Mjg3OQ_size_16_color_FFFFFF_t_70]

[20190811214319571.png]: /images/20211101/06ab6888738a4c7b87c07e32009fb48a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl8zNjM3Mjg3OQ_size_16_color_FFFFFF_t_70]: /images/20211101/9dde16d327a5427491a12aaaefdebd32.png