如何使用通道在 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中文網其他相關文章！