diff options
Diffstat (limited to 'main.go')
-rw-r--r-- | main.go | 6 |
1 files changed, 4 insertions, 2 deletions
@@ -12,7 +12,7 @@ import ( const ( subExt = ".vtt" - outdir = "data/utterances" + outdir = "/mnt/nvme/data" ffCmdOut = "data/ff_commands" timeSep = "-->" metadataPath = "data/metadata.json" @@ -180,13 +180,15 @@ func main() { fmt.Println("filled queue, starting workers") - workers := 10 + workers := 100 for i := 0; i < workers; i++ { go worker(queue, i, done) } for { if len(queue) == 0 { + // give time for workers to finish + time.Sleep(3 * time.Second) done <- true close(done) close(queue) |