How to stop a goroutine ?

Question

I have a goroutine that calls a method, and passes returned value on a channel: ch := make(chan int, 100) go func(){ for { ch <- do_stuff() } }() How do I stop such a goroutine?

Gopher · Accepted Answer

If your goroutine exists solely to process the items coming out of the chan, you can make use of the "close" builtin and the special receive form for channels. That is, once you're done sending items on the chan, you close it. Then inside your goroutine you get an extra parameter to the receive operator that shows whether the channel has been closed. Here is a complete example (the waitgroup is used to make sure that the process continues until the goroutine completes): package main import "sync" func main() { var wg sync.WaitGroup wg.Add(1) ch := make(chan int) go func() { for { foo, ok := <-ch if !ok { println("done") wg.Done() return } println(foo) } }() ch <- 1 ch <- 2 ch <- 3 close(ch) wg.Wait() } https://play.golang.org/p/yEVGmyXrhuX

Aditya Agrawal · Answer

Typically, you pass the goroutine a (possibly separate) signal channel. That signal channel is used to push a value into when you want the goroutine to stop. The goroutine polls that channel regularly. As soon as it detects a signal, it quits. quit := make(chan bool) go func() { for { select { case <- quit: return default: // Do other stuff } } }() // Do stuff // Quit goroutine quit <- true

Go Language

Similar Questions

How to stop goroutine execution on timeout?

How to convert an int value to string in Go?

What do the operators '<<' and '>>' do in Go?

On a mission to build Next-Gen Community Platform for Developers

Facebook

Twitter

Linkedin

Instagram