Go 語言基礎——協程(goroutine)&共享內存線程安全

協程(goroutine)是更輕量級的線程

比Java中的線程效率更高

協程語法

go func() {
   //...
}()

一旦主goroutine中的代碼執行完畢,當前的Go程序就會結束運行,不管其餘的 goroutine是否已經在運行了。

讓主goroutine等待其它 goroutine:

for i := 0; i < 10; i++ {
	go func() {
		fmt.Println(i)
	}()
}
time.Sleep(time.Millisecond * 1000)
//goroutine 完成的時間極可能小於設置的等待時間,那麼這就會形成多餘的等待時間

怎麼才能讓goroutine執行完後馬上執行下一個goroutine呢?

go語言提供的WaitGroup能夠實現這樣的功能.

代碼改造:

var wg sync.WaitGroup
for i := 0; i < 10; i++ {
    wg.Add(1)//每啓動一個協程增長一個等待
	go func() {
		fmt.Println(i)
        wg.Done()//告訴協成等待的事務已經完成
	}()
}
/*
這樣咱們就不用設置等待時間了,可是執行輸出的內容是這樣的: 3 7 4 8 8 8 9 10 10 10, 很顯然這種方式不能保證goroutine拿到惟一整數
*/

如何保證每一個線程拿到的數是唯一的?

代碼改造:

var wg sync.WaitGroup
for i := 0; i < 10; i++ {
    wg.Add(1)//每啓動一個協程增長一個等待
	go func(j int) {//把j只是個形參能夠任意命名
		fmt.Println(j)
        wg.Done()//告訴協成等待的事務已經完成
	}(i)//把實參i傳遞給形參j
}
//執行結果:0 2 1 6 3 4 5 8 7 9

咱們把i值傳遞給j,i的變化不會影響j的值,因此輸出的結果是惟一的

共享內存線程安全

func TestCounter(t *testing.T) {
	counter := 0
	for i := 0; i < 5000; i++ {
		go func() {
			counter++
		}()
	}
	time.Sleep(1 * time.Second)
	t.Logf("counter = %d", counter)
}
//執行結果: 4760 出現了線程安全的問題

和大多數語言同樣go也支持加鎖保證線程的安全:

func TestCounterWaitGroup(t *testing.T) {
	var mut sync.Mutex//建立鎖對象
	var wg sync.WaitGroup
	counter := 0
	for i := 0; i < 5000; i++ {
		wg.Add(1)//每啓動一個協程增長一個等待
		go func() {
			defer func() {
				mut.Unlock()//釋放鎖
			}()
			mut.Lock()//開啓鎖
			counter++
			wg.Done()//告訴協成等待的事務已經完成
		}()
	}
	wg.Wait()//等待協程
	t.Logf("counter = %d", counter)

}

---

**** 碼字不易若是對你有幫助請給個關注****

**** 愛技術愛生活 QQ羣: 894109590****