golang goroutine 并发递增

package main

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

func main() {
    var wg sync.WaitGroup
    var a int32 = 0 // goroutine指向的外部变量地址
    for i := 1; i < 100; i++ {
        wg.Add(1)
        go func(incr int32) {
            for !atomic.CompareAndSwapInt32(&a,a,a+incr) { // 悲观锁
            }
            wg.Done()
        }(int32(i))
    }
    wg.Wait()
    fmt.Println(a)
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!