Function NewWorkQueue

pkg/utilds/workqueue.go:15–21

(workFn func(T))

}

func NewWorkQueue[T any](workFn func(T)) *WorkQueue[T] {
	wq := &WorkQueue[T]{
		workFn: workFn,
	}
	wq.cond = sync.NewCond(&wq.lock)
	return wq
}

func (wq *WorkQueue[T]) Enqueue(item T) bool {
	wq.lock.Lock()