Feat: attempt concurrency

1 files changed, 19 insertions, 7 deletions

diff --git a/main.go b/main.go
index 13729b9..52db403 100644
--- a/main.go
+++ b/main.go
@@ -9,7 +9,6 @@ import (
 	"strings"
 )
 
-// TODO: to config file
 const (
 	subExt          = ".vtt"
 	outdir          = "data/utterances"
@@ -73,9 +72,10 @@ func linesToUtterances(lines []string, fd *FileData) []*Utterance {
 			RightTime: strings.TrimSpace(splitted[1]),
 			FD:        fd,
 		}
-		u.OutPath = fmt.Sprintf("%s/%s_%s_%s.opus", outdir, fd.AudioBase,
+		u.OutPath = fmt.Sprintf("%s/%s_%s_%s.wav", outdir, fd.AudioBase,
 			u.LeftTime, u.RightTime)
 
+		// todo: compare and filter time
 		if u.LeftTime == u.RightTime {
 			continue
 		}
@@ -162,15 +162,27 @@ func main() {
 		panic(err)
 	}
 
-	filteredUtterances := []*Utterance{}
+	// filteredUtterances := []*Utterance{}
+
+	// === concurrent ===
+	queue := make(chan *Utterance, 1000)
+	done := make(chan bool, 1)
+
+	workers := 10
+	for i := 0; i < workers; i++ {
+		go worker(queue, i, done)
+	}
 
 	for _, ut := range utterances {
 		if _, err := os.Stat(ut.OutPath); os.IsNotExist(err) {
-			if err := cutoutClipAndTranscode(ut); err == nil {
-				filteredUtterances = append(filteredUtterances, ut)
-			}
+			queue <- ut
+			// if err := cutoutClipAndTranscode(ut); err == nil {
+			// 	filteredUtterances = append(filteredUtterances, ut)
+			// }
 		}
 	}
-	newMeta := utterancesToFileTextMap(filteredUtterances)
+	done <- true
+	close(done)
+	newMeta := utterancesToFileTextMap(utterances)
 	writeCSV(mapToCSV(newMeta))
 }