diff options
| -rw-r--r-- | mocking-bob/more-paralellism.go | 84 |
1 files changed, 84 insertions, 0 deletions
diff --git a/mocking-bob/more-paralellism.go b/mocking-bob/more-paralellism.go new file mode 100644 index 0000000..64b841b --- /dev/null +++ b/mocking-bob/more-paralellism.go @@ -0,0 +1,84 @@ +package main + +import ( + // we want *real* random + "crypto/rand" + "fmt" + "os" + "unicode" +) + +func main() { + jobList := make(chan [2]chan rune, 4096) + + // spin up an appropriate amount of workers for this task + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + go worker(jobList) + + outchans := make(chan chan rune, 4096) + done := make(chan struct{}, 1) + + go func(o chan chan rune) { + for r := range o { + fmt.Printf("%c", <-r) + } + done <- struct{}{} + }(outchans) + + for _, str := range os.Args[1:] { + for _, c := range str { + in := make(chan rune, 1) + out := make(chan rune, 1) + outchans <- out + jobList <- [2]chan rune{in, out} + in <- c + close(in) + } + out := make(chan rune, 1) + outchans <- out + out <- ' ' + close(out) + } + close(outchans) + + <-done +} + +func worker(jobList chan [2]chan rune) { + b := make([]byte, 1) + for job := range jobList { + c := <-job[0] + _, err := rand.Read(b) + if err != nil { + job[1] <- c + close(job[1]) + continue + } + if b[0]%2 == 0 { + // switch case + if unicode.ToUpper(c) == c { + job[1] <- unicode.ToLower(c) + } else { + job[1] <- unicode.ToUpper(c) + } + close(job[1]) + continue + } + job[1] <- c + close(job[1]) + } +} |