diff options
Diffstat (limited to 'workers.go')
-rw-r--r-- | workers.go | 15 |
1 files changed, 11 insertions, 4 deletions
@@ -2,15 +2,22 @@ package main import "fmt" -func worker(queue chan *Utterance, worknumber int, geshaft chan *Utterance) { +func worker(queue chan *Utterance, done chan bool, worknumber int, geshaft chan *Utterance) { for { if len(queue) == 0 { fmt.Println("empty queue, number", worknumber) return } - ut := <-queue - if err := cutoutClipAndTranscode(ut); err == nil { - geshaft <- ut + select { + + case ut := <-queue: + if err := cutoutClipAndTranscode(ut); err == nil { + geshaft <- ut + } + + case <-done: + fmt.Println("done signal, number", worknumber) + return } } } |