Search⌘ K
AI Features
Home
Courses
The Way to Go

Chaining and Parallelizing Computation

Explore how to chain goroutines and parallelize computations across CPU cores using Go channels. Understand techniques to manage large-scale concurrent tasks and optimize data processing pipelines with goroutines. Gain practical insights into using synchronization patterns and buffers to improve performance.

We'll cover the following...

Chaining goroutines

The following ...

Go (1.6.2)
package main
import (
"flag"
"fmt"
)
var ngoroutine = flag.Int("n", 100000, "how many goroutines")
func f(left, right chan int) { left <- 1+<-right }
func main() {
  flag.Parse()
  leftmost := make(chan int)
  var left, right chan int = nil, leftmost
  for i := 0; i < *ngoroutine; i++ {
    left, right = right, make(chan int)
    go f(left, right)
  }
  right <- 0 // start the chaining
  x := <-leftmost // wait for completion
  fmt.Println(x) // 100000, approx. 1.5 s
}

In this little program, you can indicate how many goroutines you want at the ...