queue

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 9, 2015 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Item

type Item interface {
	ID() string
	Do() bool
	Stop()
}

Item represents a simple item in the queue

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Queue is a simple item queue

func NewQueue

func NewQueue() *Queue

NewQueue returns a new queue

func (*Queue) Add

func (q *Queue) Add(item Item)

Add tries to Do the item, if it's not possible, add the item to the queue for future tries

func (*Queue) Process

func (q *Queue) Process()

Process tries to Do all the items in the queue and remove the items successfully done

func (*Queue) Remove

func (q *Queue) Remove(items ...Item)

Remove an item from the queue

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL