chanutil

package

v1.0.0 Latest Latest Go to latest Published: Dec 28, 2019 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ChanQ struct {
	// contains filtered or unexported fields
}

Flexible channel queue (no fixed length).

func NewChanQ(inSize, outSize int) *ChanQ

func (ch *ChanQ) In() chan<- interface{}

func (ch *ChanQ) Out() <-chan interface{}

type NBChan struct {
	// contains filtered or unexported fields
}

func NewNBChan() *NBChan

func (ch *NBChan) NewBufChan(n int)

func (ch *NBChan) Receive(timeout time.Duration) (interface{}, error)

func (ch *NBChan) Send(v interface{}) error

Non-blocking send