queue

Documentation

Index

• type RingBuffer
  • func NewRingBuffer(size int) *RingBuffer
  • func (r *RingBuffer) Cap() uint64
  • func (r *RingBuffer) Len() uint64
  • func (r *RingBuffer) Pop() *task.Task
  • func (r *RingBuffer) Push(t *task.Task) bool

Types

type RingBuffer

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

func NewRingBuffer

func NewRingBuffer(size int) *RingBuffer

func (*RingBuffer) Cap

func (r *RingBuffer) Cap() uint64

func (*RingBuffer) Len

func (r *RingBuffer) Len() uint64

func (*RingBuffer) Pop

func (r *RingBuffer) Pop() *task.Task

func (*RingBuffer) Push

func (r *RingBuffer) Push(t *task.Task) bool