GO concurrent demo

Go_concurrent_demo.go

package main

// similar to Matt Aimonetti's example, read his blog!
// http://matt.aimonetti.net/posts/2012/11/27/real-life-concurrency-in-go/
func concurrently(integers []int) []int {
  // make a channel to talk to the goroutines
  ch := make(chan int)

  // prepare a slice with all the results
  responses := []int{}

  // iterate through all the input and send
  // them each to their own goroutine for calc
  for _, i := range integers {
      go func(i int) {
          ch <- i * i
      }(i)
  }

  // loop forever until return is reached
  for {
      // pull a result off from the channel
      r := <-ch
      // add it to responses (duh), end
      // the loop if we're done
      responses = append(responses, r)
      if len(responses) == len(integers) {
          return responses
      }
  }
}

func main() {
  concurrently([]int{1, 2, 3, 4, 5, 6, 7, 8})
}