Golang并发控制：sync.WaitGroup使用详解

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《Golang并发控制详解：sync.WaitGroup使用指南》，这篇文章主要讲到等等知识，如果你对Golang相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

使用sync.WaitGroup实现并发控制的关键在于正确匹配Add()和Done()调用。1. sync.WaitGroup通过Add(delta int)增加计数器，启动goroutine前调用确保计数准确；2. Done()用于减少计数器，通常配合defer确保goroutine退出时执行；3. Wait()阻塞主协程直到所有任务完成。常见错误包括Add()与Done()次数不匹配或在Done()后再次调用Add()，需仔细检查代码逻辑避免panic。结合context.Context可实现更高级的并发控制，如超时取消机制，提升程序灵活性与健壮性。其他并发工具如sync.Mutex、chan等也应根据场景灵活选用。

Golang实现高效并发控制，核心在于合理利用sync.WaitGroup。它能让你优雅地等待一组goroutine完成，避免程序提前退出或资源泄漏。掌握sync.WaitGroup的用法，是写出健壮并发程序的关键一步。

解决方案：

sync.WaitGroup主要用于等待一组goroutine执行完毕。它内部维护一个计数器，初始值为0。通过Add(delta int)增加计数器，Done()减少计数器，Wait()阻塞直到计数器归零。

下面是一个简单的例子：

package main

import (
    "fmt"
    "sync"
    "time"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done() // 确保goroutine退出时计数器减一
    fmt.Printf("Worker %d starting\n", id)
    time.Sleep(time.Second) // 模拟耗时操作
    fmt.Printf("Worker %d done\n", id)
}

func main() {
    var wg sync.WaitGroup

    for i := 1; i <= 5; i++ {
        wg.Add(1) // 启动一个goroutine，计数器加一
        go worker(i, &wg)
    }

    wg.Wait() // 阻塞，直到所有goroutine执行完毕
    fmt.Println("All workers done")
}

这个例子中，我们启动了5个worker goroutine，每个goroutine模拟执行一个耗时操作。wg.Add(1)确保每个goroutine启动时计数器加一，wg.Done()确保goroutine退出时计数器减一。wg.Wait()则会阻塞main goroutine，直到所有worker goroutine执行完毕。

如何避免sync.WaitGroup使用中的常见错误？

最常见的错误之一是Add()和Done()的调用不匹配。如果Add()的次数少于实际启动的goroutine数量，Wait()可能会提前返回，导致程序逻辑错误。反之，如果Add()的次数多于实际启动的goroutine数量，可能会导致panic。

另一个常见错误是在Done()之后再次调用Add()。这会导致计数器变为负数，并在Wait()时引发panic。

解决这些问题的关键在于仔细检查代码，确保Add()和Done()的调用次数匹配，并且不会在Done()之后再次调用Add()。

更高级的并发控制技巧：结合sync.WaitGroup和context.Context

在复杂的并发场景中，我们可能需要提前取消正在执行的goroutine。这时，可以结合sync.WaitGroup和context.Context来实现更精细的控制。

package main

import (
    "context"
    "fmt"
    "sync"
    "time"
)

func workerWithContext(ctx context.Context, id int, wg *sync.WaitGroup) {
    defer wg.Done()

    fmt.Printf("Worker %d starting\n", id)
    defer fmt.Printf("Worker %d done\n", id)

    for {
        select {
        case <-ctx.Done():
            fmt.Printf("Worker %d cancelled\n", id)
            return
        case <-time.After(time.Second): // 模拟耗时操作
            fmt.Printf("Worker %d working\n", id)
        }
    }
}

func main() {
    var wg sync.WaitGroup
    ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
    defer cancel()

    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go workerWithContext(ctx, i, &wg)
    }

    wg.Wait()
    fmt.Println("All workers done")
}

在这个例子中，我们使用context.WithTimeout创建了一个带有超时时间的context。每个worker goroutine都会监听context的Done channel，一旦context被取消，goroutine就会退出。这样，我们就可以在一定时间内等待goroutine执行完毕，或者在超时后强制取消它们。

除了sync.WaitGroup，还有哪些Golang并发控制工具值得学习？

Golang提供了丰富的并发控制工具，除了sync.WaitGroup，还有sync.Mutex、sync.RWMutex、sync.Cond、sync.Once、chan等。

• sync.Mutex用于保护共享资源，防止并发访问导致的数据竞争。
• sync.RWMutex是读写锁，允许多个goroutine同时读取共享资源，但只允许一个goroutine写入共享资源。
• sync.Cond用于goroutine之间的条件同步，允许goroutine等待某个条件成立后再继续执行。
• sync.Once用于确保某个函数只执行一次，常用于单例模式的实现。
• chan是goroutine之间通信的管道，可以用于传递数据和同步信号。

选择合适的并发控制工具，取决于具体的应用场景。理解这些工具的原理和用法，可以帮助我们写出更高效、更健壮的并发程序。

今天关于《Golang并发控制：sync.WaitGroup使用详解》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！