chanx
Unbounded chan with ringbuffer.
Refer to the below articles and issues:
- golang/go#20352
- https://stackoverflow.com/questions/41906146/why-go-channels-limit-the-buffer-size
- https://medium.com/capital-one-tech/building-an-unbounded-channel-in-go-789e175cd2cd
- https://erikwinter.nl/articles/2020/channel-with-infinite-buffer-in-golang/
Usage
If you want to use it with Go 1.17.x or below, you can use github.com/smallnest/[email protected].
Since github.com/smallnest/[email protected], it support Go generic.
ch := NewUnboundedChan(1000)
// or ch := NewUnboundedChanSize(10,200,1000)
go func() {
for ...... {
...
ch.In <- ... // send values
...
}
close(ch.In) // close In channel
}()
for v := range ch.Out { // read values
fmt.Println(v)
}