Versions in this module Expand all Collapse all v1 v1.0.0 May 10, 2019 Changes in this version + type ConcurrentQueue struct + func NewConcurrentQueue(bufferSize int) *ConcurrentQueue + func (cq *ConcurrentQueue) ChanIn() chan<- interface{} + func (cq *ConcurrentQueue) ChanOut() <-chan interface{} + func (cq *ConcurrentQueue) Start() + func (cq *ConcurrentQueue) Stop() + type GCQueue struct + func NewGCQueue(newItem func() interface{}, returnQueueSize int, ...) *GCQueue + func (q *GCQueue) Return(item interface{}) + func (q *GCQueue) Take() interface{}