chanutil

Documentation

Index

• type ChanQ
  • func NewChanQ(inSize, outSize int) *ChanQ
  • func (ch *ChanQ) In() chan<- interface{}
  • func (ch *ChanQ) Out() <-chan interface{}
• type NBChan
  • func NewNBChan() *NBChan
  • func NewNBChan2(n int, logS string) *NBChan
  • func (ch *NBChan) NewBufChan(n int)
  • func (ch *NBChan) Receive(timeout time.Duration) (interface{}, error)
  • func (ch *NBChan) Send(v interface{}) error
  • func (ch *NBChan) SetBufChanToZero()

Types

type ChanQ

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

Flexible channel queue (no fixed length).

func NewChanQ

func NewChanQ(inSize, outSize int) *ChanQ

func (*ChanQ) In

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

func (*ChanQ) Out

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

type NBChan

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

Non-blocking channel.

func NewNBChan

func NewNBChan() *NBChan

func NewNBChan2

func NewNBChan2(n int, logS string) *NBChan

func (*NBChan) NewBufChan

func (ch *NBChan) NewBufChan(n int)

func (*NBChan) Receive

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

Receives or fails after timeout.

func (*NBChan) Send

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

Send now if a receiver is watching, or fails (non-blocking) with error.

func (*NBChan) SetBufChanToZero

func (ch *NBChan) SetBufChanToZero()

Setting the channel to zero allows a send to fail immediatly if there is no receiver waiting.