buffer

Documentation

Index

• type Unbounded
  • func NewUnbounded() *Unbounded
  • func (b *Unbounded) Get() <-chan interface{}
  • func (b *Unbounded) Load()
  • func (b *Unbounded) Put(t interface{})

Types

type Unbounded

type Unbounded struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Unbounded 一个支持任意长度的channel实现 如果有性能要求，将interface类型实例出来，避免一次转换。

func NewUnbounded

func NewUnbounded() *Unbounded

NewUnbounded 构建Unbounded

func (*Unbounded) Get

func (b *Unbounded) Get() <-chan interface{}

Get 获取unbounded的读channel

func (*Unbounded) Load

func (b *Unbounded) Load()

Load 将积压队列中的头部数据提取到channel，并将队列整体前移一位。

func (*Unbounded) Put

func (b *Unbounded) Put(t interface{})

Put 输入一个新的信息