queue

Documentation

Index

• type ConcurrentQueue
  • func New(queueSize int, concurrency int) *ConcurrentQueue
  • func (cq *ConcurrentQueue) DispatchProcess(process func(interface{}))
  • func (cq *ConcurrentQueue) Enqueue(item T)
• type T

Types

type ConcurrentQueue

type ConcurrentQueue struct {
	Queue       chan T
	QueueSize   int
	Concurrency int
}

func New

func New(queueSize int, concurrency int) *ConcurrentQueue

func (*ConcurrentQueue) DispatchProcess

func (cq *ConcurrentQueue) DispatchProcess(process func(interface{}))

func (*ConcurrentQueue) Enqueue

func (cq *ConcurrentQueue) Enqueue(item T)

type T

type T interface{}