queue

Documentation

Index

• type RequestDoubleQueue
  • func NewRequestDoubleQueue(size1 int, size2 int) *RequestDoubleQueue
  • func (this *RequestDoubleQueue) Clear()
  • func (this *RequestDoubleQueue) Get() interface{}
  • func (this *RequestDoubleQueue) GetCapacity1() int
  • func (this *RequestDoubleQueue) GetCapacity2() int
  • func (this *RequestDoubleQueue) GetNoWait() interface{}
  • func (this *RequestDoubleQueue) GetTimeout(timeout int) interface{}
  • func (this *RequestDoubleQueue) Put1(v interface{}) bool
  • func (this *RequestDoubleQueue) Put2(v interface{}) bool
  • func (this *RequestDoubleQueue) PutForce1(v interface{}) bool
  • func (this *RequestDoubleQueue) PutForce2(v interface{}) bool
  • func (this *RequestDoubleQueue) SetCapacity(sz1 int, sz2 int)
  • func (this *RequestDoubleQueue) Size() int
  • func (this *RequestDoubleQueue) Size1() int
  • func (this *RequestDoubleQueue) Size2() int
  • func (this *RequestDoubleQueue) ToString1() string
  • func (this *RequestDoubleQueue) ToString2() string
• type RequestQueue
  • func NewRequestQueue(size int) *RequestQueue
  • func (this *RequestQueue) Clear()
  • func (this *RequestQueue) Get() interface{}
  • func (this *RequestQueue) GetCapacity() int
  • func (this *RequestQueue) GetNoWait() interface{}
  • func (this *RequestQueue) GetTimeout(timeout int) interface{}
  • func (this *RequestQueue) Put(v interface{}) bool
  • func (this *RequestQueue) PutForce(v interface{}) bool
  • func (this *RequestQueue) SetCapacity(size int)
  • func (this *RequestQueue) Size() int

Types

type RequestDoubleQueue

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

func NewRequestDoubleQueue

func NewRequestDoubleQueue(size1 int, size2 int) *RequestDoubleQueue

func (*RequestDoubleQueue) Clear

func (this *RequestDoubleQueue) Clear()

func (*RequestDoubleQueue) Get

func (this *RequestDoubleQueue) Get() interface{}

func (*RequestDoubleQueue) GetCapacity1

func (this *RequestDoubleQueue) GetCapacity1() int

func (*RequestDoubleQueue) GetCapacity2

func (this *RequestDoubleQueue) GetCapacity2() int

func (*RequestDoubleQueue) GetNoWait

func (this *RequestDoubleQueue) GetNoWait() interface{}

func (*RequestDoubleQueue) GetTimeout

func (this *RequestDoubleQueue) GetTimeout(timeout int) interface{}

func (*RequestDoubleQueue) Put1

func (this *RequestDoubleQueue) Put1(v interface{}) bool

func (*RequestDoubleQueue) Put2

func (this *RequestDoubleQueue) Put2(v interface{}) bool

func (*RequestDoubleQueue) PutForce1

func (this *RequestDoubleQueue) PutForce1(v interface{}) bool

func (*RequestDoubleQueue) PutForce2

func (this *RequestDoubleQueue) PutForce2(v interface{}) bool

func (*RequestDoubleQueue) SetCapacity

func (this *RequestDoubleQueue) SetCapacity(sz1 int, sz2 int)

func (*RequestDoubleQueue) Size

func (this *RequestDoubleQueue) Size() int

func (*RequestDoubleQueue) Size1

func (this *RequestDoubleQueue) Size1() int

func (*RequestDoubleQueue) Size2

func (this *RequestDoubleQueue) Size2() int

func (*RequestDoubleQueue) ToString1

func (this *RequestDoubleQueue) ToString1() string

func (*RequestDoubleQueue) ToString2

func (this *RequestDoubleQueue) ToString2() string

type RequestQueue

type RequestQueue struct {
	Failed     func(interface{})
	Overflowed func(interface{})
	// contains filtered or unexported fields
}

func NewRequestQueue

func NewRequestQueue(size int) *RequestQueue

func (*RequestQueue) Clear

func (this *RequestQueue) Clear()

func (*RequestQueue) Get

func (this *RequestQueue) Get() interface{}

func (*RequestQueue) GetCapacity

func (this *RequestQueue) GetCapacity() int

func (*RequestQueue) GetNoWait

func (this *RequestQueue) GetNoWait() interface{}

func (*RequestQueue) GetTimeout

func (this *RequestQueue) GetTimeout(timeout int) interface{}

func (*RequestQueue) Put

func (this *RequestQueue) Put(v interface{}) bool

func (*RequestQueue) PutForce

func (this *RequestQueue) PutForce(v interface{}) bool

func (*RequestQueue) SetCapacity

func (this *RequestQueue) SetCapacity(size int)

func (*RequestQueue) Size

func (this *RequestQueue) Size() int