INNER CODE UNIT · Go

processFilesConCurrently

cgzirim/seek-tune · server/cmdHandlers.go:289

func processFilesConCurrently(filePaths []string, force bool) {
	maxWorkers := runtime.NumCPU() / 2
	numFiles := len(filePaths)

	if numFiles == 0 {
		return
	}

	if numFiles < maxWorkers {
		maxWorkers = numFiles
	}

	jobs := make(chan string, numFiles)
	results := make(chan error, numFiles)

	for w := 0; w < maxWorkers; w++ {
		go func(workerID int) {
			for filePath := range jobs {

View source record →