queue.go

fileList := make(chan string, len(files))
done := make(chan int, availableCores)

for i := 0; i < availableCores; i++ {
	go threadedRead(i, columns, fileList, done)
}

for i := 0; i < len(files); i++ {
	fileList <- "sql_tmp/" + files[i].Name()
}

close(fileList)

for i := 0; i < len(files); i++ {
	fmt.Println("Chunk #", i, "read")
	<-done
}