go并发与锁

在Go语言中，并发和锁是非常重要的概念。Go语言提供了几种内置的同步原语，其中最常用的是go routines（goroutines）和channel，以及互斥锁（sync.Mutex）和读写锁（sync.RWMutex）。

以下是一些示例代码，展示了如何在Go中使用并发和锁：

1. 使用互斥锁（Mutex）来同步对共享资源的访问：

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    counter int
    wg sync.WaitGroup
    mutex sync.Mutex
)
 
func increment() {
    defer wg.Done()
    for i := 0; i < 2; i++ {
        mutex.Lock()
        counter++
        mutex.Unlock()
    }
}
 
func main() {
    wg.Add(2)
    go increment()
    go increment()
    wg.Wait()
    fmt.Println("Counter:", counter)
}

2. 使用读写锁（RWMutex）来提高读取操作的并发性能：

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    counter int
    wg sync.WaitGroup
    rwMutex sync.RWMutex
)
 
func readCounter() int {
    rwMutex.RLock()
    defer rwMutex.RUnlock()
    return counter
}
 
func increment() {
    defer wg.Done()
    for i := 0; i < 2; i++ {
        rwMutex.Lock()
        counter++
        rwMutex.Unlock()
    }
}
 
func main() {
    wg.Add(1)
    go increment()
    wg.Wait()
    fmt.Println("Counter:", readCounter())
}

3. 使用channel来同步并发任务并保持数据的一致性：

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    data = make(map[int]int)
    wg sync.WaitGroup
    mutex sync.Mutex
)
 
func updateData(key, value int) {
    defer wg.Done()
    mutex.Lock()
    data[key] = value
    mutex.Unlock()
}
 
func main() {
    wg.Add(2)
    go updateData(1, 10)
    go updateData(2, 20)
    wg.Wait()
    mutex.Lock()
    fmt.Println("Data:", data)
    mutex.Unlock()
}

以上代码展示了如何在Go中使用互斥锁、读写锁和channel来同步并发操作，保护共享资源不受破坏，并确保数据的一致性。