airylinus/UnlimitSizeChan

golang，无限缓冲的channel

unlimitSizeChan

无限缓存的channel，golang实现

• 无限缓存，无需在创建channle时指定大小
• 底层buf采用双向环形链表结构，可基于数据量进行自适应扩缩容
• 永远不阻塞写
• 仅在无数据时阻塞读
• 读写仍通过channle操作
• channle被关闭后，未读取的数据仍然可读

请参阅以下文章和问题：

1. golang/go#20352
2. https://stackoverflow.com/questions/41906146/why-go-channels-limit-the-buffer-size
3. https://medium.com/capital-one-tech/building-an-unbounded-channel-in-go-789e175cd2cd
4. https://erikwinter.nl/articles/2020/channel-with-infinite-buffer-in-golang/

Usage

ch := NewUnlimitSizeChan(1000)
// or ch := NewUnlitSizeChanSize(100,200)

go func() {
    for ...... {
        ...
        ch.In <- ... // send values
        ...
    }

    close(ch.In) // close In channel
}()


for v := range ch.Out { // read values
    fmt.Println(v)
}

设计和实现思路请参考作者博客: https://www.cnblogs.com/yinbiao/p/15784545.html