Java多线程 对象未完成初始化就把对象提供给外界--注册监听器(观察者模式)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package com.thread.background;

/**
 * 类名称:EventListenerError
 * 类描述: 运用观察者模式   注册监听器导致的对象未完成初始化就把对象提供给外界
 *
 * @author: https://javaweixin6.blog.csdn.net/
 * 创建时间:2020/9/1 20:34
 * Version 1.0
 */
public class EventListenerError {
    int count;

    public EventListenerError(MySource source) {
        //匿名内部类的方式 , 创建 EventListener接口实例
        source.registerListener(new EventListener() {
            @Override
            public void onEvent(Event e) {
                //监听器, 监听到东西的时候, 就打印获取的值
                System.out.println("n我得到的数字是   "+count);
            }
        });

        //模拟其他业务逻辑
        for (int i = 0; i < 10000; i++) {
            System.out.print(i);
        }

        //count初始化
        count = 100;
    }

    public static void main(String[] args) {
        MySource mySource = new MySource();

        new Thread(() -> {
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            mySource.eventCome(new Event() {
            });
        }).start();

        EventListenerError eventListenerError = new EventListenerError(mySource);
    }


    static class MySource {

        private EventListener listener;

        void registerListener(EventListener eventListener) {
            this.listener = eventListener;
        }

        /**
         * 每次有事件来临的时候, 触发eventCome方法
         * @param e
         */
        void eventCome(Event e) {
            if (listener != null) {
                listener.onEvent(e);
            } else {
                System.out.println("还未初始化完毕!  ");
            }
        }

    }

    interface EventListener {
        void onEvent(Event e);
    }

    interface Event {

    }

}