queue

type Layer ¶ added in v0.5.3

type Layer interface {
	// Request a Go-routine for the given lock tag.
	Enqueue(lockTag string, action func(slot int, lockTag string))
}

Layer is an interface that specifies a way for the vault to obtain a Go-routine for a given lock tag. Once the queue layer notifies the vault, the vault knows that for a given lock tag, it is safe to operate as the thread assigned to that lock tag is the one making the notifying call to the provided callback.

func NewMultiQueue(
	concurrency int,
	capacity int,
) Layer

func NewSingleQueue(
	size int,
) Layer

type SingleQueue ¶

type SingleQueue struct {
	// contains filtered or unexported fields
}

func (singleQueue *SingleQueue) Enqueue(lockTag string, action func(int, string))