ringqueue

Documentation

Index

• func Delay(z int)
• type RingQueue
  • func New[T any](capacity uint32) *RingQueue[T]
  • func (q *RingQueue[T]) Capaciity() uint32
  • func (q *RingQueue[T]) Get() (val T, ok bool, quantity uint32)
  • func (q *RingQueue[T]) Gets(values []T) (gets, quantity uint32)
  • func (q *RingQueue[T]) Put(val T) (ok bool, quantity uint32)
  • func (q *RingQueue[T]) Puts(values []T) (puts, quantity uint32)
  • func (q *RingQueue[T]) Quantity() uint32
  • func (q *RingQueue[T]) String() string

Functions

func Delay

func Delay(z int)

Types

type RingQueue

type RingQueue[T any] struct {
	// contains filtered or unexported fields
}

lock free queue

func New

func New[T any](capacity uint32) *RingQueue[T]

func (*RingQueue[T]) Capaciity

func (q *RingQueue[T]) Capaciity() uint32

func (*RingQueue[T]) Get

func (q *RingQueue[T]) Get() (val T, ok bool, quantity uint32)

get queue functions

func (*RingQueue[T]) Gets

func (q *RingQueue[T]) Gets(values []T) (gets, quantity uint32)

gets queue functions

func (*RingQueue[T]) Put

func (q *RingQueue[T]) Put(val T) (ok bool, quantity uint32)

put queue functions

func (*RingQueue[T]) Puts

func (q *RingQueue[T]) Puts(values []T) (puts, quantity uint32)

puts queue functions

func (*RingQueue[T]) Quantity

func (q *RingQueue[T]) Quantity() uint32

func (*RingQueue[T]) String

func (q *RingQueue[T]) String() string