Waitgroups: What they are, how to use them and what changed with Go 1.25

Summary

Imagine the following problem: you need to process hundreds of records and generate a single output. One way to solve this is to process each record sequentially and unify the output only at the end. However, this can be extremely slow, depending on the time spent processing each record. Another way is to process them concurrently, speeding up the overall time. In my post about introduction to concurrency, I talked a bit about goroutines and channels. Now, I’ve decided to talk about waitgroups, a way to simplify the management of multiple goroutines.Waitgroups are part of the sync package, and their use is relatively simple. For each goroutine you start, you must add 1 to the sync counter, and then you have to wait for all goroutines to finish their work. Each goroutine must reduce the counter by 1 to indicate its completion. For example:func Before1_25() { r := rand.IntN(10) wg := sync.WaitGroup{} wg.Add(1) // Wait for 1 more goroutine to process go doSomethingTheOldWay(&wg, r) // Doing something async wg.Wait() // Wait until all goroutines finishes } func doSomethingTheOldWay(wg *sync.WaitGroup, sleep int) { defer wg.Done() // Tell the waitgroup you're done. It the same as wg.Add(-1) time.Sleep(time.Duration(sleep) * time.Second) } Although they are easy to use, you must always ensure the correct number of goroutines in the waitgroup. In other words, for every goroutine added with wg.Add, you must have a wg.Done. If this doesn’t happen, it can cause a deadlock during wg.Wait. This occurs, for example, if we add a goroutine to the waitgroup and never call wg.Done. The reverse of this problem is finishing more goroutines than were added to the waitgroup, which generates a panic with the message panic: sync: negative WaitGroup counter. However, this problem is intermittent, as the main process might finish before the goroutine. To avoid these cases, the goleak library implements a goroutine leak validator.func TestCases(t *testing.T) { t.Run("Before1_25", func(t *tes...