queue

Documentation

Overview

queue

Index

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

Functions

func Delay

func Delay(z int)

Types

type Cache

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

type Queue

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

Queue Lockless free queue

func NewQueue

func NewQueue[T any](capacity uint32) *Queue[T]

func (*Queue[T]) Capacity

func (q *Queue[T]) Capacity() uint32

func (*Queue[T]) Get

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

Get queue functions

func (*Queue[T]) Gets

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

Gets queue functions

func (*Queue[T]) Put

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

Put queue functions

func (*Queue[T]) Puts

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

Puts queue functions

func (*Queue[T]) Quantity

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

func (*Queue[T]) String

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