queue

README

queue

This is a FIFO queue for Go based on container/list.

Features

• first in first out -- of course ;)
• goroutine safe
• both: blocking and non-blocking reading
• Close to release blocking
• all data is still read on Close

Benchmarks

BenchmarkQueue_Push-12                	10000000	       122 ns/op	      48 B/op	       1 allocs/op
BenchmarkQueue_Pop-12                 	30000000	      42.3 ns/op	       0 B/op	       0 allocs/op
BenchmarkQueue_PopBlocking-12         	30000000	      42.8 ns/op	       0 B/op	       0 allocs/op
BenchmarkQueue_Push_PopBlocking-12    	10000000	       129 ns/op	      48 B/op	       1 allocs/op

Documentation

Index

• type Queue
  • func NewQueue() *Queue
  • func (s *Queue) Close() error
  • func (s *Queue) Pop() (interface{}, bool)
  • func (s *Queue) PopBlocking() (interface{}, bool)
  • func (s *Queue) Push(n interface{}) error

Types

type Queue

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

Queue is a basic FIFO queue.

func NewQueue

func NewQueue() *Queue

NewQueue returns a new FIFO queue.

func (*Queue) Close

func (s *Queue) Close() error

Close closes the queue. Use this to release all PopBlocking calls. The queue will be emptied before PopBlocking returns false.

func (*Queue) Pop

func (s *Queue) Pop() (interface{}, bool)

Pop removes and returns a node from the queue. The bool value is false if the queue was empty.

func (*Queue) PopBlocking

func (s *Queue) PopBlocking() (interface{}, bool)

PopBlocking removes and returns a node from the queue. It blocks until an element is available or the queue is closed. The bool value is false if the queue has been emptied and was closed.

func (*Queue) Push

func (s *Queue) Push(n interface{}) error

Push adds a node to the queue. Will fail if the queue has been closed.