golang sync多次调用

Go语言中的sync包提供了一种简单而有效的方式，允许多个goroutine之间进行安全的共享数据访问。通过使用互斥锁、条件变量和其他同步原语，开发者可以确保数据的正确性和一致性。在本文中，我们将重点介绍sync包中的多次调用方法，它可以在多次执行相同操作时提供更灵活的控制。

Once

sync包提供了Once类型，它可以确保某个函数只会在多个goroutine中被调用一次。Once类型内部使用了一个互斥锁和一个标记位，以确保在多个goroutine同时调用Do方法时，只有第一个调用会执行函数，后续调用会直接返回。

例如，我们可以定义一个函数，用于初始化一些全局变量，但是我们希望只在第一次调用时执行初始化操作：

var initializeOnce sync.Once
var myData *Data

func initData() {
    // 初始化数据
    myData = &Data{...}
}

func GetData() *Data {
    initializeOnce.Do(initData)
    return myData
}

在上面的示例中，我们使用了sync.Once来确保initData函数只会在第一次调用GetData时执行。在后续的调用中，Once类型内部的标记位会标记为已执行，所以Do方法会直接返回而不会再次执行initData。

WaitGroup

另一个常用的sync包中的类型是WaitGroup。它可以用于等待一组goroutine完成工作，然后再继续执行主程序。

WaitGroup有三个重要的方法：Add、Done和Wait。我们可以通过这些方法来实现对一组goroutine的同步。下面是一个简单的示例：

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()

    // 执行一些工作
}

func main() {
    var wg sync.WaitGroup

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

    wg.Wait()
    fmt.Println("所有工作已完成")
}

在上面的示例中，我们首先创建了一个WaitGroup实例。然后，我们使用Add方法通知WaitGroup需要等待一个goroutine的完成。在worker函数中，我们在函数结束时调用了Done方法，表示该worker已完成工作。最后，我们在主函数中调用了Wait方法，用于等待所有的worker完成。

Mutex

sync包中最基础的类型就是Mutex（互斥锁）。它提供了两个重要的方法：Lock和Unlock。通过使用互斥锁，我们可以确保在任意时刻只有一个goroutine可以访问共享资源。

下面是一个简单的示例，演示了如何使用互斥锁来保护一段临界区代码：

var mutex sync.Mutex
var count int

func increment() {
    mutex.Lock()
    count++
    mutex.Unlock()
}

func main() {
    var wg sync.WaitGroup

    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            increment()
        }()
    }

    wg.Wait()
    fmt.Println("count:", count)
}

在上面的示例中，我们定义了一个全局变量count和一个互斥锁mutex。在increment函数中，我们使用Lock方法获取锁，并对count进行递增操作，并在操作完成后使用Unlock方法释放锁。在主函数中，我们创建了5个goroutine，并使用WaitGroup来等待它们执行完毕。

总之，sync包提供了许多用于多次调用的同步原语，包括Once、WaitGroup和Mutex。这些原语可以帮助我们在并发编程中保证数据的正确性和一致性，并且提供了更灵活的控制。当我们需要在多个goroutine之间共享数据时，使用这些同步原语是非常重要的，它们可以确保我们的程序运行正确且高效。