// sigterm package main import ( "fmt" "log" "os" "os/signal" "syscall" ) func exit() { for i := 0; i < opts.Concurrent; i++ { log.Println("EXIT ", i) fmt.Println("EXIT ", i) loop[i] = false // done[i] <- true } } func setTerm() { c := make(chan os.Signal, 1) signal.Notify(c, os.Interrupt) signal.Notify(c, syscall.SIGTERM) go func() { <-c exit() }() }