queue

Documentation

Index

• type LockFreeQueue
  • func NewLockFreeQueue() *LockFreeQueue
  • func (q *LockFreeQueue) Dequeue() interface{}
  • func (q *LockFreeQueue) Enqueue(v interface{})
  • func (q *LockFreeQueue) Length() uint64

Types

type LockFreeQueue

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

LockFreeQueue implements lock-free FIFO freelist based queue. ref: https://dl.acm.org/citation.cfm?doid=248052.248106

func NewLockFreeQueue

func NewLockFreeQueue() *LockFreeQueue

NewLockFreeQueue creates a new lock-free queue.

func (*LockFreeQueue) Dequeue

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

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

func (*LockFreeQueue) Enqueue

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

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

func (*LockFreeQueue) Length

func (q *LockFreeQueue) Length() uint64

Length returns the length of the queue.