golang怎么设置锁

在Golang中，锁是用于实现并发控制的重要机制。通过使用锁，我们可以保护共享资源，以确保在多个goroutine同时访问时不会发生竞态条件。本文将介绍如何在Golang中设置和使用锁。

互斥锁（Mutex）

Golang中最基本的锁类型是互斥锁（Mutex），它通过调用Lock()方法来获取锁，Unlock()方法来释放锁。当某个goroutine获取到锁后，其他goroutine必须等待该goroutine释放锁才能获取锁。

下面是一个使用互斥锁的简单例子：

import (
    "sync"
)

var (
    counter int
    mutex   sync.Mutex
)

func increment() {
    mutex.Lock()
    defer mutex.Unlock()

    counter++
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            increment()
        }()
    }
    wg.Wait()

    fmt.Println(counter)
}

在上面的例子中，我们定义了一个counter变量来进行计数，通过互斥锁mutex保证了counter的并发安全访问。每个goroutine在调用increment函数时会先获取锁，执行完后再释放锁。

读写锁（RWMutex）

互斥锁的特点是同时只有一个goroutine可以获取到锁，这在某些场景下可能会产生性能问题。Golang提供了读写锁（RWMutex）来解决这个问题。

RWMutex分为读模式和写模式。多个goroutine可以同时获取读锁，而获取写锁的goroutine必须等待没有读锁或写锁的时候才能获取到锁。

下面是一个使用读写锁的例子：

import (
    "sync"
)

var (
    counter int
    rwMutex sync.RWMutex
)

func readCounter() {
    rwMutex.RLock()
    defer rwMutex.RUnlock()

    fmt.Println(counter)
}

func increment() {
    rwMutex.Lock()
    defer rwMutex.Unlock()

    counter++
}

func main() {
    var wg sync.WaitGroup
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            increment()
            readCounter()
        }()
    }
    wg.Wait()
}

上面的例子中，我们新增了一个readCounter函数来读取counter的值。通过读写锁rwMutex，在执行读操作时使用RLock()方法获取读锁，执行写操作时使用Lock()方法获取写锁。这样可以保证在写操作时其他goroutine无法进行读操作。

条件变量（Cond）

互斥锁和读写锁用于解决并发访问共享资源的问题，但在某些情况下，我们需要等待某个条件满足后再继续执行。Golang提供了条件变量（Cond）来实现这样的需求。

条件变量结合互斥锁或读写锁一起使用。当某个goroutine发现条件不满足时，调用条件变量的Wait()方法进入等待状态，直到其他goroutine调用条件变量的Signal()或Broadcast()方法将其唤醒。

下面是一个使用条件变量的例子：

import (
    "sync"
)

var (
    counter      int
    conditionVar sync.Cond
)

func increment() {
    conditionVar.L.Lock()
    defer conditionVar.L.Unlock()

    counter++

    conditionVar.Signal()
}

func main() {
    var wg sync.WaitGroup
    conditionVar.L = new(sync.Mutex)
    conditionVar.Broadcast()

    wg.Add(1)
    go func() {
        defer wg.Done()
        conditionVar.L.Lock()
        for counter == 0 {
            conditionVar.Wait()
        }
        fmt.Println(counter)
        conditionVar.L.Unlock()
    }()

    increment()
    wg.Wait()
}

在上面的例子中，我们新增了一个goroutine，并使用条件变量conditionVar等待counter不为0。在increment函数中，每次递增counter后调用conditionVar的Signal()方法唤醒等待的goroutine。

通过以上介绍，我们了解了在Golang中如何设置锁。无论是互斥锁、读写锁还是条件变量，都是在多个goroutine之间实现同步和并发控制的重要工具。