go-concurrency-guide

Go Concurrency Guide

1. Fondamentaux Go — critères de décision

Situation	Choix
Méthode modifie le receiver	Pointer receiver *T
Méthode lit seulement	Value receiver T (sauf struct > ~64 bytes)
Comportement partagé	Interface implicite (duck typing)
Cleanup garanti	defer f.Close() / defer mu.Unlock()
Erreur attendue	Retour (T, error), jamais panic

type Store struct{ db *sql.DB }

func (s *Store) Get(ctx context.Context, id int) (User, error) {
    var u User
    err := s.db.QueryRowContext(ctx, "SELECT ...").Scan(&u.Name)
    return u, fmt.Errorf("store.Get %d: %w", id, err)
}

2. Goroutines et channels

Unbuffered = synchrone (handshake). Buffered = découplage, ne pas abuser.

// Done pattern — arrêt propre
done := make(chan struct{})
go func() {
    defer close(done)
    for {
        select {
        case <-ctx.Done():
            return
        case job := <-jobs:
            process(job)
        }
    }
}()

// Fan-out vers N workers
jobs := make(chan Task, 100)
var wg sync.WaitGroup
for range N {                          // Go 1.22+
    wg.Add(1)
    go func() {
        defer wg.Done()
        for t := range jobs { handle(t) }
    }()
}
close(jobs)
wg.Wait()

Règle d'or : le producteur ferme le channel, jamais le consommateur.

3. Patterns de concurrence — quand utiliser quoi

Pattern	Usage	Snippet
Worker pool	CPU-bound, N fixe	make(chan Job, buf) + N goroutines
Pipeline	Transformations en chaîne	channels en entrée/sortie de chaque stage
Semaphore	Limiter I/O concurrent	sem := make(chan struct{}, max)
errgroup	Goroutines avec erreur remontée	golang.org/x/sync/errgroup

// Semaphore — max 10 requêtes HTTP parallèles
sem := make(chan struct{}, 10)
for _, url := range urls {
    sem <- struct{}{}
    go func(u string) {
        defer func() { <-sem }()
        fetch(u)
    }(url)
}

// errgroup — propagation d'erreur
g, ctx := errgroup.WithContext(ctx)
for _, item := range items {
    item := item
    g.Go(func() error { return process(ctx, item) })
}
if err := g.Wait(); err != nil { ... }