README
¶
golang-queue
queue provides an efficient implementation of a multi-producer, single-consumer lock-free queue
Reference
MpscQueue: github.com/AsynkronIT/protoactor-go
Interface
type Queue interface {
Push(v interface{}) bool
Pop() interface{}
Empty() bool
Size() int64
}
usage
q := NewRingQueue(size)
q.Push(value)
//note: pop only be call from single goroutine
v = q.Pop()
benchmark
test env : i5 8th GEN / 16G
2000 goroutine * 10000 push && pop
RingQueue: 420ns/op
MpscQueue: 640ns/op
CQueue: 830ns/op
goos: linux
goarch: amd64
pkg: queue
BenchmarkRingqueue
BenchmarkRingqueue-8 1 8396128600 ns/op 697504768 B/op 20001304 allocs/op
BenchmarkMpscqueue
BenchmarkMpscqueue-8 1 12918583100 ns/op 800511184 B/op 40002378 allocs/op
BenchmarkCQueue
BenchmarkCQueue-8 1 16738020500 ns/op 800215496 B/op 40001946 allocs/op
PASS
coverage: 64.9% of statements
ok queue 38.523s
Documentation
¶
Overview ¶
Package mpsc provides an efficient implementation of a multi-producer, single-consumer lock-free queue.
The Push function is safe to call from multiple goroutines. The Pop and Empty APIs must only be called from a single, consumer goroutine.
The Push function is safe to call from multiple goroutines. The Pop and Empty APIs must only be called from a single, consumer goroutine.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CQueue ¶
type CQueue struct {
// contains filtered or unexported fields
}
CQueue is a concurrent unbounded queue which uses two-Lock concurrent queue qlgorithm.
type MpscQueue ¶
type MpscQueue struct {
// contains filtered or unexported fields
}
func NewMpscQueue ¶
func NewMpscQueue() *MpscQueue
func (*MpscQueue) Empty ¶
Empty returns true if the queue is empty
Empty must be called from a single, consumer goroutine
func (*MpscQueue) Pop ¶
func (q *MpscQueue) Pop() interface{}
Pop removes the item from the front of the queue or nil if the queue is empty
Pop must be called from a single, consumer goroutine
type Queue ¶
Queue is a FIFO data structure. Push puts a value into its tail, Pop removes a value from its head.
Source Files