esqueue

Documentation

Index

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

Functions

func Delay

func Delay(z int)

Types

type EsQueue

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

lock free queue

func NewEsQueue

func NewEsQueue[T any](capacity uint32) *EsQueue[T]

func (*EsQueue[T]) Capaciity

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

func (*EsQueue[T]) Get

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

get queue functions

func (*EsQueue[T]) Gets

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

gets queue functions

func (*EsQueue[T]) Put

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

put queue functions

func (*EsQueue[T]) Puts

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

puts queue functions

func (*EsQueue[T]) Quantity

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

func (*EsQueue[T]) String

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