Go 语言中的观察者模式
在软件工程中,当事件发生时需要通知订阅者集合时,就会使用观察者模式发生在对象内部。在 C 中实现此目的的通用框架是 boost::signals。本问题探讨了如何在 Go 中复制此功能,使用一个示例演示多个订阅者如何向发布者注册并接收通知。
解决方案
观察者模式可以使用通道在 Go 中轻松实现。它们的内在目的是促进并发 goroutine 之间的通信。
type Publisher struct { listeners []chan *Msg } type Subscriber struct { Channel chan *Msg } func (p *Publisher) Sub(c chan *Msg) { p.appendListener(c) } func (p *Publisher) Pub(m *Msg) { for _, c := range p.listeners { c <- Msg } } func (s *Subscriber) ListenOnChannel() { for { data := <-s.Channel //Process data } } func main() { for _, v := range subscribers { p.Sub(v.Channel) go v.ListenOnChannel() } //Some kind of wait here }
虽然此示例不是完整的工作代码示例,但它为使用通道在 Go 中实现观察者模式提供了坚实的基础。
以上是如何使用通道在 Go 中实现观察者模式?的详细内容。更多信息请关注PHP中文网其他相关文章!