Golang Goroutines cheatsheet

goroutines_cheatsheet.go

// from the talk https://www.youtube.com/watch?v=PTE4VJIdHPg
// futures
future := make(chan int, 1)
go func() {future <- process() }()
result := <-future

// async await
c := make(chan int, 1)
go func() { c <- process() }() // async
v := <-c // await

// Scatter/gather
type result struct {  
    val int
    err error
}

//Scatter
c := make(chan result, 10)
for i := 0, i < cap(c); i++ {
  go func() {
    val, err := process()
    c <- result{val, err}
  }()
}

// Gather
var results []int  
for i := 0; i < cap(c); i++ {  
    res := <-c
    if res.err != nil {
        log.Printf("could not process request %d\n", i)
        continue
    }
    results = append(results, res.val)
}


// Some resources
// https://wohldani.com/scatter-gather/
// https://talks.golang.org/2012/concurrency.slide#1
// https://talks.golang.org/2013/advconc.slide#11