workqueue

Documentation

Index

• type FifoQueue
  • func New() *FifoQueue
  • func NewNamedQueue(name string) *FifoQueue
  • func (f *FifoQueue) Add(item interface{})
  • func (f *FifoQueue) Done(item interface{})
  • func (f *FifoQueue) Get() (item interface{}, shutdown bool)
  • func (f *FifoQueue) Len() int
  • func (f *FifoQueue) Shutdown()
  • func (f *FifoQueue) ShuttingDown() bool
• type Queue

Types

type FifoQueue

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

FifoQueue implement abstract quene

func New

func New() *FifoQueue

New create a new work queue with default name

func NewNamedQueue

func NewNamedQueue(name string) *FifoQueue

NewNamedQueue create a new work queue with name

func (*FifoQueue) Add

func (f *FifoQueue) Add(item interface{})

Add make item to be processing

func (*FifoQueue) Done

func (f *FifoQueue) Done(item interface{})

Done make processing item to be done

func (*FifoQueue) Get

func (f *FifoQueue) Get() (item interface{}, shutdown bool)

Get return an item to be processed

func (*FifoQueue) Len

func (f *FifoQueue) Len() int

Len return current quee length

func (*FifoQueue) Shutdown

func (f *FifoQueue) Shutdown()

Shutdown close the queue and exit all processing items

func (*FifoQueue) ShuttingDown

func (f *FifoQueue) ShuttingDown() bool

ShuttingDown check current shutting down state

type Queue

type Queue interface {
	Add(item interface{})
	Len() int
	Get() (item interface{}, shutdown bool)
	Done(item interface{})
	Shutdown()
	ShuttingDown() bool
}

Queue for abstract work queue