Можете использовать контекст снаружи от создания горутин и передавать им его.
В горутине в select слушайте ctx.Done() и если пришло сообщение в него раньше, чем горутина закончила работу — делайте return
Как-то так (если ctx оповестил раньше, то горутина завершится), в данном случае горутина слушает др канал (в некоторых случаях необходимо еще в цикл завернуть)
https://go.dev/play/p/HeBD8QSdPhU
package main
import (
"context"
"flag"
"fmt"
"log"
"os"
"os/signal"
"syscall"
"time"
)
const ProgramStoppedByUser = 100
func main() {
ctx, _ := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
var amountOfWorkers int
flag.IntVar(&amountOfWorkers, "a", 2, "-a <amount of workers>")
flag.Parse()
times := make(chan int64, 1)
// Запускаем ваши воркеры
WriteInChannel(times, amountOfWorkers, ctx)
for {
select {
// Главная программа завершится: закроет канал и вернет код ответа
case <-ctx.Done():
close(times)
log.Println("Stopped by user")
os.Exit(ProgramStoppedByUser)
default:
// Если нет завершения — плодим время, можно это вынести в горутины
// (но не забудьте ее тоже через контекст закрыть) и убрать текущий цикл for
// Также закрытие канала в пишущую горутину поместить
now := time.Now().UnixNano()
times <- now
time.Sleep(1 * time.Second)
}
}
}
func WriteInChannel(times chan int64, amountWorkers int, ctx context.Context) {
for i := 0; i < amountWorkers; i++ {
go Worker(i, times, ctx)
}
}
func Worker(id int, ch <-chan int64, ctx context.Context) {
for {
select {
case <-ctx.Done():
fmt.Printf("Worker %d is closed \n", id)
return
case data, ok := <-ch:
if !ok {
fmt.Print("Chan already closed \n")
return
}
fmt.Printf("Data: %d (Worker %d) \n", data, id)
}
}
}