queue

type ArrayDelayQueue[E comparable] struct {
	// contains filtered or unexported fields
}

type ArrayPriorityQueue[E comparable] struct {
	// contains filtered or unexported fields
}

type ArrayPriorityQueueOption[E comparable] func(*ArrayPriorityQueue[E])

type CmpEnum int64

type DQItem[E comparable] interface {
	Expiration() int64
	PQItem[E]
}

type DelayQueue[E comparable] interface {
	Offer(item E, expiration int64)
	// PollToChan Asynchronous function
	PollToChan(nowFn func() int64, C infra.SendOnlyChannel[E])
	Len() int64
}

type PQItem[E comparable] interface {
	ReadOnlyPQItem[E]
	SetIndex(idx int64)
	SetPriority(pri int64)
}

type PQItemLessThenComparator[E comparable] func(i, j ReadOnlyPQItem[E]) CmpEnum

type PriorityQueue[E comparable] interface {
	Len() int64
	Push(item PQItem[E])
	Pop() ReadOnlyPQItem[E]
	Peek() ReadOnlyPQItem[E]
}

type ReadOnlyPQItem[E comparable] interface {
	Index() int64
	Value() E
	Priority() int64
}

type RingBuffer[T any] interface {
	Capacity() uint64
	LoadEntryByCursor(cursor uint64) RingBufferEntry[T]
}

type RingBufferCursor interface {
	Next() uint64
	NextN(n uint64) uint64
	Load() uint64
	CompareAndSwap(old, new uint64) bool
}

type RingBufferEntry[T any] interface {
	GetValue() T
	GetCursor() uint64
	Store(cursor uint64, value T)
}