mapqueue

Documentation

Index

• type MQEntry
• type MapQueue
  • func MakeMapQueue(queueSize int) *MapQueue
  • func (mq *MapQueue) Enqueue(id string, fn func()) error

Types

type MQEntry

type MQEntry struct {
	Lock    *sync.Mutex
	Running bool
	Queue   chan func()
}

type MapQueue

type MapQueue struct {
	Lock      *sync.Mutex
	M         map[string]*MQEntry
	QueueSize int
}

func MakeMapQueue

func MakeMapQueue(queueSize int) *MapQueue

func (*MapQueue) Enqueue

func (mq *MapQueue) Enqueue(id string, fn func()) error