GO言語で並列実行するサンプルコード。ワーカーのキャンセル機能付き - Qiita

package main import ( "context" "fmt" "time" "github.com/pkg/errors" ) type Result struct { Task Task Err error } type Task struct { Bar int } func worker(workerID int, ctx context.Context, taskChannel <-chan Task, resultChannel chan<- Result) { // taskCannelがなくなるまで動作する for task := range taskChannel { select { case <-ctx.Done(): // 親からcancel()が実行された場合、動きを止める fmt.Printf("[%d] got Cancel\n", workerI