Versions in this module Expand all Collapse all v1 v1.0.0 Jan 21, 2020 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()
Go to main page