func NewIgnoreSink() *IgnoreSink { sink := &IgnoreSink{ in: make(chan interface{},1024), } sink.init() return sink } func (ignore *IgnoreSink) init() { go func() { for { _, ok := <-ignore.in if !ok { break } } }() } 优化 直接丢弃数据

如果你的业务确实只需要忽略接收到的数据而不需要进行处理，那么可以直接使用一个空的for循环来丢弃数据。这样可以省略掉WaitGroup的使用，代码更加简洁。下面是优化后的代码示例：

type IgnoreSink struct {
    in chan interface{}
}

func NewIgnoreSink() *IgnoreSink {
    sink := &IgnoreSink{
        in: make(chan interface{}, 1024),
    }
    sink.init()
    return sink
}

func (ignore *IgnoreSink) init() {
    go func() {
        for range ignore.in {
            // 直接丢弃数据
        }
    }()
}

func (ignore *IgnoreSink) Close() {
    close(ignore.in)
}

在这个优化后的代码中，我们直接使用一个空的for循环来丢弃数据，避免了使用WaitGroup的开销。同时，我们增加了一个Close方法来关闭channel。