增加间隔

zhangqian

2023-12-20 1960a054785d1f81e69abe84b43073ed9df638e0

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 problem
 
import "fmt"
 
// Subject 主题接口
type Subject interface {
    Register(observer Observer)
    Deregister(observer Observer)
    Notify(data interface{})
}
 
// Observer 观察者接口
type Observer interface {
    Update(data interface{})
}
 
// BaseSubject 主题基类实现
type BaseSubject struct {
    observers []Observer
}
 
func (s *BaseSubject) Register(observer Observer) {
    s.observers = append(s.observers, observer)
}
 
func (s *BaseSubject) Deregister(observer Observer) {
    for i, obs := range s.observers {
        if obs == observer {
            s.observers = append(s.observers[:i], s.observers[i+1:]...)
            return
        }
    }
}
 
func (s *BaseSubject) Notify(data interface{}) {
    for _, obs := range s.observers {
        obs.Update(data)
    }
}
 
//// 主题实现
//type ConcreteSubject struct {
//    BaseSubject
//}
//
//// 观察者实现
//type ConcreteObserver struct {
//    name string
//}
//
//func (o *ConcreteObserver) Update(data interface{}) {
//    fmt.Printf("%s 收到通知：%v\n", o.name, data)
//}
//
//func main() {
//    subject := &ConcreteSubject{}
//
//    observer1 := &ConcreteObserver{name: "观察者1"}
//    observer2 := &ConcreteObserver{name: "观察者2"}
//
//    subject.Register(observer1)
//    subject.Register(observer2)
//
//    subject.Notify("新数据1")
//    subject.Deregister(observer1)
//
//    subject.Notify("新数据2")
//}
 
// 主题实现
type EventSubject struct {
    BaseSubject
}
 
// 观察者实现
type EventObserver struct {
    name string
}
 
func (o *EventObserver) Update(data interface{}) {
    fmt.Printf("%s 收到通知：%v\n", o.name, data)
}