dstructs

Documentation

Index

• type FlQueue
  • func NewFlQueue[T any]() *FlQueue[T]
  • func (m *FlQueue[T]) Flush() []T
  • func (m *FlQueue[T]) Push(r T)

Types

type FlQueue

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

FlQueue is a manual-flush queue that is thread-safe.

func NewFlQueue

func NewFlQueue[T any]() *FlQueue[T]

func (*FlQueue[T]) Flush

func (m *FlQueue[T]) Flush() []T

func (*FlQueue[T]) Push

func (m *FlQueue[T]) Push(r T)