close(channel) 用于实现观察者模式答案

【问题标题】：close(channel) used to implement the observer patternclose(channel) 用于实现观察者模式
【发布时间】：2018-09-17 07:30:15
【问题描述】：

当接收到没有特定顺序的“退出”信号时，除了调用其他函数之外，我还需要按需停止 HTTP 服务器。

在我尝试实现observer pattern 之类的东西时，我发现“方便”创建一个频道（quit := make(chan struct{})，比如说“主题”，然后在每个 goroutines 上“ observers”在该频道上收听 <-quit 等到更改后再继续。

我一次触发所有功能的方法是关闭频道close(quit) 而不是写入它，我已经尝试过这个并且到目前为止工作，但想知道这种方法是否有一些缺点或者是否有更好的/实现类似行为/模式的惯用方式。

package main

import (
    "log"
    "net/http"
    "sync"
    "time"
)

func main() {
    var wg sync.WaitGroup

    srv := &http.Server{Addr: ":8080"}

    wg.Add(1)
    go func() {
        log.Println(srv.ListenAndServe())
        wg.Done()
    }()

    quit := make(chan struct{})
    go func() {
        <-quit
        if err := srv.Close(); err != nil {
            log.Printf("HTTP server Shutdown: %v", err)
        }
    }()

    wg.Add(1)
    go func() {
        <-quit
        log.Println("just waiting 1")
        wg.Done()
    }()

    wg.Add(1)
    go func() {
        <-quit
        log.Println("just waiting 2")
        wg.Done()
    }()

    <-time.After(2 * time.Second)
    close(quit)
    wg.Wait()
}

https://play.golang.org/p/uIfMJfN6xQy

【问题讨论】：

关闭频道以向任意数量的各方广播单个事件是很常见的事情。（恕我直言，在这里使用 struct{} 过于聪明了。）
这是一种合理的方法，也正是context.Context 的工作原理。

标签： go observer-pattern

【解决方案1】：

我会说你的方式足够好，但缺乏一些优雅。

您可以使用sync.Cond 实现所需的行为：

https://golang.org/pkg/sync/#Cond
How to correctly use sync.Cond?

【讨论】：