Skip to content

Instantly share code, notes, and snippets.

@santosh
Created June 17, 2021 12:19
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save santosh/b275ecda6e95b1972e83fb50efb636ce to your computer and use it in GitHub Desktop.
Save santosh/b275ecda6e95b1972e83fb50efb636ce to your computer and use it in GitHub Desktop.
Generator concurrency pattern.
package main
import (
"fmt"
"math/rand"
"time"
)
func boring(msg string) <-chan string { // Returns receive-only channel of strings.
c := make(chan string)
go func() { // We launch the goroutine from inside the function
for i := 0; ; i++ {
c <- fmt.Sprintf("%s %d", msg, i)
time.Sleep(time.Duration(rand.Intn(1e3)) * time.Millisecond)
}
}()
return c
}
func main() {
c := boring("boring!")
for i := 0; i < 20; i++ {
fmt.Printf("You say: %q\n", <-c) // Receive expression is just a value.
}
fmt.Println("You're boring; I'm leaving.")
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment