如何使用通道在 Go 中实现观察者模式？

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中文网其他相关文章！