所有 goroutine 都在休眠的问题，观察者模式的演示

大家好，今天本人给大家带来文章《所有 goroutine 都在休眠的问题，观察者模式的演示》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

demo到这里就结束了，我尝试使用channel来实现观察者模式，但是遇到了致命错误。 如果我在测试中使用简单的通道，一切都会顺利。

也许 go 中的观察者模式不应该这样。

如果有人能帮忙，我将不胜感激，非常感谢~~~

package observer

import "reflect"

type isubject interface {
    register(observer iobserver) error
    cancelregister(observer iobserver) error
    publish() error
}

type subject struct {
    registerchannels []chan string `json:"registerchannels"`
}

func (s *subject) register(observer observer) error {
    observer.listenchannel = make(chan string)
    s.registerchannels = append(s.registerchannels, observer.listenchannel)
    return nil
}

func (s *subject) cancelregister(observer observer) error {
    for index, val := range s.registerchannels {
        if reflect.deepequal(val, observer.listenchannel) {
            s.registerchannels = append(s.registerchannels[:index], s.registerchannels[index+1:]...)
        }
    }
    return nil
}

func (s *subject) publish(msg string) error {
    for i := 0; i < len(s.registerchannels); i++ {
        s.registerchannels[i] <- msg
    }
    return nil
}

package observer

import "fmt"

type iobserver interface {
    subscribe()
}

type observer struct {
    listenchannel chan string `json:"listenchannel"`
}

func (observer observer) subscribe() {
    msg := <-observer.listenchannel
    fmt.println(msg)
}

func Test_Sub(t *testing.T) {
    s1 := Subject{}
    o1 := Observer{}
    err := s1.Register(o1)
    if err != nil {
        return
    }
    go func() {
        o1.Subscribe()
        fmt.Println(1)
    }()
    fmt.Println(2)
    err = s1.Publish("hahaha")
    if err != nil {
        return
    }
}

正确答案

您必须通过引用（而不是通过值）传递观察者对象，或者您应该使观察者 listenchannel 位于 register 之外（在测试中的 test_sub 函数中）。

通过引用如下：

func (s *subject) register(observer observer) error {
    s.registerchannels = append(s.registerchannels, observer.listenchannel)
    return nil
}

func test_sub(t *testing.t) {
    s1 := subject{}
    o1 := observer{}
    err := s1.register(&o1)
    ...
}

或者在register函数之外进行制作，如下所示：

func (s *subject) register(observer observer) error {
    s.registerchannels = append(s.registerchannels, observer.listenchannel)
    return nil

}

func test_sub(t *testing.t) {
    s1 := subject{}
    o1 := observer{}
    o1.listenchannel = make(chan string)
    err := s1.register(o1)
    ...
}

此外，在您的发布功能中，我认为最好使用 go 例程写入频道， 因为如果观察者无法读取其通道，它将锁定订阅中的所有其他观察者

func (s *Subject) Publish(msg string) error {
  for i := 0; i < len(s.RegisterChannels); i++ {
    go func(i int) { s.RegisterChannels[i] <- msg }(i)
  }
  return nil
}

以上就是《所有 goroutine 都在休眠的问题，观察者模式的演示》的详细内容，更多关于的资料请关注golang学习网公众号！