queue

Documentation

Index

• type LKQueue
  • func NewLKQueue() *LKQueue
  • func (q *LKQueue) Dequeue() interface{}
  • func (q *LKQueue) Enqueue(v interface{})

Types

type LKQueue

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

LKQueue is a lock-free unbounded queue. See https://colobu.com/2020/08/14/lock-free-queue-in-go/

func NewLKQueue

func NewLKQueue() *LKQueue

NewLKQueue returns an empty queue.

func (*LKQueue) Dequeue

func (q *LKQueue) Dequeue() interface{}

Dequeue removes and returns the value at the head of the queue. It returns nil if the queue is empty.

func (*LKQueue) Enqueue

func (q *LKQueue) Enqueue(v interface{})

Enqueue puts the given value v at the tail of the queue.