Go语言线程安全之互斥锁与读写锁

package main

import (
    "fmt"
    "sync"
)

var x int = 0

var wg sync.WaitGroup

func add() {
    defer wg.Done()
    for i := 0; i < 5000; i++ {
        x++
    }
}
func main() {
    wg.Add(2)
    go add()
    go add()
    wg.Wait()
    fmt.Println(x)
}
/*
打印结果：(每次打印不一样,正常的结果应该是10000)
    6051
    5059
    5748
    10000
*/

package main

import (
    "fmt"
    "sync"
)

var x int = 0

var wg sync.WaitGroup

// 创建一个锁对象
var lock sync.Mutex

func add() {
    defer wg.Done()
    for i := 0; i < 5000; i++ {
        //加锁
        lock.Lock()
        x++
        //解锁
        lock.Unlock()
    }
}
func main() {
    wg.Add(2)
    //开启两个线程
    go add()
    go add()
    wg.Wait()
    fmt.Println(x)
}
/*
打印结果：
    全为10000
*/

package main

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

var (
    x      = 0
    rwlock sync.RWMutex
    wg     sync.WaitGroup
)

func write() {
    defer wg.Done()
    rwlock.Lock()
    x++
    rwlock.Unlock()
}

func read() {
    wg.Done()
    //开启读锁
    rwlock.RLock()
    fmt.Println(x)
    //释放读锁
    rwlock.RUnlock()
}
func main() {
    start := time.Now()
    for i := 0; i < 100; i++ {
        wg.Add(1)
        go write()
    }
    // time.Sleep(time.Second)
    for i := 0; i < 10000; i++ {
        wg.Add(1)
        go read()
    }
    wg.Wait()
    fmt.Println(time.Now().Sub(start))
}

func f2(a <-chan int, b chan<- int) {
    for {
        x, ok := <-a
        if !ok {
            break
        }
        fmt.Println(x)
        b <- x * 10
    }
    // 确保b通道只关闭一次
    once.Do(func() {
        close(b)
    })
}

package main

import (
    "fmt"
    "sync"
    "sync/atomic"
)

var x int64 = 0

var wg sync.WaitGroup

/*
    原子操作是将数据进行打包枷锁,直接通过指定的函数进行相应的操作
    可以使用load读取、store写入、add修改、swap交换。
    // 类似于读取一个变量、对一个变量进行赋值
*/
func addone() {
    // 没有加锁进行并发的话，会产生数据丢失的情况
    defer wg.Done()
    // x++

    // 不用加锁也可以使用的行云流水
    // 第一个参数是进行操作的数据,第二个是增加的步长
    atomic.AddInt64(&x, 1)

}
func csf() {
    // 进行比较相等则将新值替换旧值
    ok := atomic.CompareAndSwapInt64(&x, 100, 200)
    fmt.Println(ok, x)
}

func main() {
    for i := 0; i < 50000; i++ {
        wg.Add(1)
        go addone()
    }
    wg.Wait()
    fmt.Println(x)
    x = 100
    csf()
    fmt.Println(123)
}