queue

type DoubleBufferQueue = DoubleBufferQueueG[byte]

type DoubleBufferQueueG[T any] interface {
	Write(p []T) (int, error)
	Read(p []T) (int, error)
	io.Closer
}

type Option[T PriorityItem] func(*priority[T])

type PriorityItem interface {
	common.Unique
	common.Weighted
}

type PriorityQueue[T PriorityItem] interface {
	SimpleQueue[T]
	Update(item T) error
	Remove(item T) (T, bool)
	Items() []T
}

type Queue[T any] interface {
	SimpleQueue[T]
	Reset()
	MustGet(i int) T
	MustPop() T
	PopN(n int) ([]T, error)
	Shift() (T, error)
	MustShift() T
	ShiftN(n int) ([]T, error)
}

type SimpleQueue[T any] interface {
	Length() int
	IsEmpty() bool
	Push(element ...T)
	Pop() (T, error)
	Reset()
}