12 | gorutine

  • 通过go关键字开启协程
func TestGoroutine(t *testing.T){
    for i:=0 ; i< 5; i++ {
        go (func(i int){
            t.Log(i)
        })(i)
    }
    t.Log("hello")
}

使用 go 关键字创建 goroutine 时，被调用函数的返回值会被忽略

  • sync.WaitGroup
func TestGoroutine(t *testing.T){
    var wg sync.WaitGroup

    for i:=0 ; i< 5; i++ {
        wg.Add(1)
        go (func(i int){
            defer wg.Done()
            t.Log(i)
        })(i)
    }
    wg.Wait()
    t.Log("hello")
}
  • 竞态条件
func TestGoroutine(t *testing.T){
    
    for i:=0 ; i< 5; i++ {
        go (func(){
            t.Log(i)
        })()
    }
    
    t.Log("hello")
}

go run -race xxx.go 使用race参数可以检测竞态条件

  • 加锁 sync.Mutex
func TestGoroutine(t *testing.T){

    var lock sync.Mutex
    for i:=0 ; i< 5; i++ {
        lock.Lock()
        go (func(){
            defer lock.Unlock()
            t.Log(i)
        })()
    }

    t.Log("hello")
}

在读多写少的环境中，可以优先使用读写互斥锁（sync.RWMutex），它比互斥锁更加高效。sync 包中的 RWMutex 提供了读写互斥锁的封装

  • atomic
  • 调整并发性能
runtime.GOMAXPROCS(runtime.NumCPU())

thead vs groutine

  • java thead stack 默认是1M
  • groutine stack 初始化为 2k

groutime vs coroutine

©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容