priorityqueue

Documentation

Index

• type PriorityMsgQueue
  • func New(n int, l int) *PriorityMsgQueue
  • func (pq *PriorityMsgQueue) Close()
  • func (pq *PriorityMsgQueue) Push(item interface{}, p int) error
  • func (pq *PriorityMsgQueue) Run(proc goprocess.Process, f func(interface{}))

Types

type PriorityMsgQueue

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

PriorityMsgQueue is a priority message queue

func New

func New(n int, l int) *PriorityMsgQueue

New return a new PriorityMsgQueue

func (*PriorityMsgQueue) Close

func (pq *PriorityMsgQueue) Close()

Close close the queue

func (*PriorityMsgQueue) Push

func (pq *PriorityMsgQueue) Push(item interface{}, p int) error

Push pushes an item to the queue specified in the priority argument and notify the loop

func (*PriorityMsgQueue) Run

func (pq *PriorityMsgQueue) Run(proc goprocess.Process, f func(interface{}))

Run is a loop popping items from the priority message queues