channels

channels copied to clipboard

Memory leak with InfiniteChannel

7

If I understand correctly, the [goroutine `ch.infiniteBuffer()`](https://github.com/eapache/channels/blob/v1.1.0/infinite_channel.go#L19) persists in memory [until all the values from inner buffer are drained](https://github.com/eapache/channels/blob/v1.1.0/infinite_channel.go#L64-L67). So, in situation where there are many writes, but only few...

tyranron

Wrap for `in` channel?

2

Hi, I'm a bit lost with examples. Let's say I have 3 channels: ``` out1 := make(chan string, 10) out2 := make(chan string, 10) in := make(chan string, 20) ```...

arvenil

The Len() of InfiniteChannel is incorrect

2

When I use InfiniteChannel, I found that Len() returned is a "case" buffered value, [https://github.com/eapache/channels/blob/master/infinite_channel.go#L58](url) A little demo shown as bellow: ``` go package main import ( "fmt" "github.com/eapache/channels" )...

vegertar

Because there's a goroutine in the middle, the current `ResizableChannel` can't be resized to a capacity of `None` (for fully unbuffered blocking mode). The best it can do is a...

eapache

Pipe with SharedBuffer channels will be dead lock

2

Fllow is the example code, the example code is from eapache/channels readme. ``` // never more than 3 elements in the pipeline at once buf := NewSharedBuffer(3) ch1 := buf.NewChannel()...

homerzhou