Skip to content

Instantly share code, notes, and snippets.

@gabibeyer
Created February 18, 2019 20:13
Show Gist options
  • Save gabibeyer/f75dcdbfb54b22493c818ad7dc06df36 to your computer and use it in GitHub Desktop.
Save gabibeyer/f75dcdbfb54b22493c818ad7dc06df36 to your computer and use it in GitHub Desktop.
package main
import (
"fmt"
"math/rand"
"sync"
"time"
)
func doTask(fileName string) (string, error) {
r := rand.Intn(100)
if r%2 == 0 {
return "", fmt.Errorf("FAKE ERROR: %s", fileName)
}
return fileName, nil
}
func main() {
rand.Seed(time.Now().UnixNano())
var wg sync.WaitGroup
workers := 4
wg.Add(workers)
jobCh := make(chan string)
errCh := make(chan error)
for i := 0; i < workers; i++ {
go func() {
defer wg.Done()
for fileName := range jobCh {
in, err := doTask(fileName)
if err != nil {
go func() {
errCh <- err
}()
break
}
fmt.Println("string processed: ", in)
}
}()
}
testStrings := []string{"one", "two", "three", "four", "five", "six", "seven", "eight", "nine", "ten"}
var err error
var errFound bool
for _, s := range testStrings {
if errFound {
break
}
select {
case jobCh <- s:
fmt.Println("adding job: ", s)
case err = <-errCh:
fmt.Println("error found", err)
errFound = true
}
}
close(jobCh)
wg.Wait()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment