concurrentqueue

Documentation

Index

• type ConcurrentQueue
  • func (s *ConcurrentQueue) Front() (interface{}, bool)
  • func (s *ConcurrentQueue) Len() int
  • func (s *ConcurrentQueue) Pop() (interface{}, bool)
  • func (s *ConcurrentQueue) PopBatch(batchSize int) ([]interface{}, bool)
  • func (s *ConcurrentQueue) Push(v interface{})

Types

type ConcurrentQueue

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

ConcurrentQueue implements a thread safe interface for unbounded FIFO queue.

func (*ConcurrentQueue) Front

func (s *ConcurrentQueue) Front() (interface{}, bool)

func (*ConcurrentQueue) Len

func (s *ConcurrentQueue) Len() int

func (*ConcurrentQueue) Pop

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

func (*ConcurrentQueue) PopBatch

func (s *ConcurrentQueue) PopBatch(batchSize int) ([]interface{}, bool)

func (*ConcurrentQueue) Push

func (s *ConcurrentQueue) Push(v interface{})