ggq

Documentation

Index

• type Consumer
• type GGQ
  • func New[T any](size uint32, consumer Consumer[T]) *GGQ[T]
  • func (q *GGQ[T]) Awake()
  • func (q *GGQ[T]) Close()
  • func (q *GGQ[T]) Consume(lower, upper uint32)
  • func (q *GGQ[T]) IsIdle() bool
  • func (q *GGQ[T]) Read() (T, bool)
  • func (q *GGQ[T]) ReadN() (T, bool)
  • func (q *GGQ[T]) Write(val T)

Types

type Consumer

type Consumer[T any] interface {
	Consume([]T)
}

type GGQ

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

func New

func New[T any](size uint32, consumer Consumer[T]) *GGQ[T]

func (*GGQ[T]) Awake

func (q *GGQ[T]) Awake()

Awake the queue if its in the idle state.

func (*GGQ[T]) Close

func (q *GGQ[T]) Close()

func (*GGQ[T]) Consume

func (q *GGQ[T]) Consume(lower, upper uint32)

func (*GGQ[T]) IsIdle

func (q *GGQ[T]) IsIdle() bool

func (*GGQ[T]) Read

func (q *GGQ[T]) Read() (T, bool)

ReadN gives way better performance, due to batching messages with lock os thread.

func (*GGQ[T]) ReadN

func (q *GGQ[T]) ReadN() (T, bool)

func (*GGQ[T]) Write

func (q *GGQ[T]) Write(val T)