Mẫu quan sát bằng ngôn ngữ Go

Question

Vấn đề này khá phổ biến: một đối tượng nên thông báo cho tất cả người đăng ký khi một số sự kiện xảy ra. Trong C++, chúng tôi có thể sử dụng boost::signals hoặc một thứ khác. Nhưng làm thế nào để làm điều này trong ngôn ngữ Go? Nó sẽ là tốt đẹp để xem một số ví dụ mã làm việc, nơi một vài đối tượng được đăng ký với một nhà xuất bản và thông báo quá trình.

Cảm ơn

Answer 1

Điều này thực sự khá đơn giản trong Go. Sử dụng kênh. Đây là thứ mà họ đang làm.

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 
} 

Rõ ràng đây không phải là mẫu mã hoạt động chính xác. Nhưng nó gần rồi.