Function NewQueue

chan_queue.go:9–17

NewQueue create a queue that specifies the number of buffers and the number of worker threads

(maxCapacity, maxThread int)

// NewQueue create a queue that specifies the number of buffers and the number of worker threads
func NewQueue(maxCapacity, maxThread int) *Queue {
	return &Queue{
		jobQueue:   make(chan Jober, maxCapacity),
		maxWorkers: maxThread,
		workerPool: make(chan chan Jober, maxThread),
		workers:    make([]*worker, maxThread),
		wg:         new(sync.WaitGroup),
	}
}

// Queue a task queue for mitigating server pressure in high concurrency situations
// and improving task processing