blob: 4255e33f31898bdbbb11816ae2df8f1befb70158 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
package main
import "fmt"
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
}
select {
case ut := <-queue:
if err := cutoutClipAndTranscode(ut); err == nil {
geshaft <- ut
}
case <-done:
fmt.Println("done signal, number", worknumber)
return
}
}
}
func cutterQueue(fQueue chan string, workerID int) {
for {
if len(fQueue) == 0 {
fmt.Println("empty queue, number", workerID)
return
}
fpath := <-fQueue
outname := fpathToOutname(fpath)
cutOnEqualParts(fpath, outname, segmentSize)
}
}
|