How to kill execution of goroutine?
A channel has a close operation that closes the channel so that a send operation on the channel cannot take place. A send operation on a closed channel will result in a panic.
When a receive operation is performed on the channel, we check if the channel is closed or not, and exit from the goroutine if the channel is closed.
Example
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
wg.Add(1)
ch := make(chan string)
go func() {
for {
channel, ok := <-ch
if !ok {
fmt.Println("Shut Down")
defer wg.Done()
return
}
fmt.Println(channel)
}
}()
ch <- "Start"
ch <- "Processing"
ch <- "Finishing"
close(ch)
wg.Wait()
}
Output
You can see the following output when you run the above program −
C:\Golang\goroutines>go run main.go
Start
Processing
Finishing
Shut Down
Most Helpful This Week
How to create goroutines in Golang?
How to use a mutex to define critical sections of code and fix race conditions?
How to play and pause execution of goroutine?
How to wait for Goroutines to Finish Execution?
What is a Goroutine?
How to fix race condition using Atomic Functions in Golang?
Catch values from Goroutines