Versions in this module Expand all Collapse all v1 v1.0.0 Nov 25, 2023 Changes in this version + type ConcurrentQueue struct + Concurrency int + Queue chan T + QueueSize int + func New(queueSize int, concurrency int) *ConcurrentQueue + func (cq *ConcurrentQueue) DispatchProcess(process func(interface{})) + func (cq *ConcurrentQueue) Enqueue(item T) + type T interface
Go to main page