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

• goroutine 可能发生并行执行
• 但 coroutine 始终顺序执行
• groutime与coroutine区别