Versions in this module Expand all Collapse all v0 v0.1.49 Jul 20, 2024 Changes in this version + type AsyncQueue interface + Initialize func(processFunc func(), workerCount int, bufferSize int) + Push func(task func()) error + type MemoryQueue struct + func NewMemoryQueue(workerCount int, bufferSize int) *MemoryQueue + func (mq *MemoryQueue) Initialize(workerCount int, bufferSize int) + func (mq *MemoryQueue) Push(task func()) error + func (mq *MemoryQueue) Stop()
Go to main page