Go語言的觀察者模式

Question

這個問題很常見：​​當某個事件發生時，對象應該通知其所有訂閱者。在C++中，我們可以使用boost::signals或其他的東西。但是如何在Go語言中做到這一點？很高興看到一些工作代碼示例，其中有幾個對象訂閱了發佈者並處理通知。

謝謝

Answer 1

這在Go中其實很簡單。使用頻道。這是他們所做的一件事。

type Publish 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 
} 

很明顯，這不是一個正確的代碼示例。但它很接近。