Concurrency in GO

Advanced Concurrency Patterns in Go

Building on the basics, here are patterns you'll actually use in production.

Worker Pools

func workerPool(jobs <-chan int, results chan<- int, workers int) {
    var wg sync.WaitGroup
    for i := 0; i < workers; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for j := range jobs {
                results <- process(j)
            }
        }()
    }
    wg.Wait()
    close(results)
}

Context Cancellation

Always pass context. Always respect cancellation.

func doWork(ctx context.Context) error {
    select {
    case <-ctx.Done():
        return ctx.Err()
    case result := <-expensiveOperation():
        return handleResult(result)
    }
}