broadcast_linkedlist

nonblocking broadcast chan

利用close(chan)的特性,来实现广播效果

example

b := NewBroadcastLinkedList()

wg := sync.WaitGroup{}
for i := 0; i < 10; i++ {
    wg.Add(1)
    go func() {
        node := b.Node()
        wg.Done()
        for {
            select {
            case <-node.C():
                println(node.Data)
                node = node.Next()
            }
        }
    }()
}
wg.Wait()

for i := 0; i < 100; i++ {
    b.Broadcast(i+1)
}

##其他开源库 https://github.com/dustin/go-broadcast

https://github.com/teivah/broadcast