in main.go [377:381]
func createQueues(queues *[]chan []byte) { for i := 0; i < workers; i++ { *queues = append(*queues, make(chan []byte, queueSize)) } }