workers.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

package main

import "fmt"

func worker(queue chan *Utterance, 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
		}
	}
}