Go 語言基礎中g(shù)oroutine和共享內(nèi)存線程安全是怎樣的

Go 語言基礎中g(shù)oroutine和共享內(nèi)存線程安全是怎樣的，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細講解，有這方面需求的人可以來學習下，希望你能有所收獲。

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

比Java中的線程效率更高

協(xié)程語法

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

一旦主goroutine中的代碼執(zhí)行完畢,當前的Go程序就會結(jié)束運行,無論其他的 goroutine是否已經(jīng)在運行了。

讓主goroutine等待其它 goroutine:

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

怎么才能讓goroutine執(zhí)行完后立刻執(zhí)行下一個goroutine呢?

go語言提供的WaitGroup可以實現(xiàn)這樣的功能.

代碼改造:

var wg sync.WaitGroup
for i := 0; i < 10; i++ {
    wg.Add(1)//每啟動一個協(xié)程增加一個等待
	go func() {
		fmt.Println(i)
        wg.Done()//告訴協(xié)成等待的事務已經(jīng)完成
	}()
}
/*
這樣我們就不用設置等待時間了,但是執(zhí)行輸出的內(nèi)容是這樣的: 3 7 4 8 8 8 9 10 10 10, 很顯然這種方式不能保證goroutine拿到唯一整數(shù)
*/

如何保證每個線程拿到的數(shù)是惟一的?

代碼改造:

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

我們把i值傳遞給j,i的變化不會影響j的值,所以輸出的結(jié)果是唯一的

共享內(nèi)存線程安全

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)
}
//執(zhí)行結(jié)果: 4760 出現(xiàn)了線程安全的問題

和大多數(shù)語言一樣go也支持加鎖保證線程的安全:

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

}

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關知識有進一步的了解或閱讀更多相關文章，請關注億速云行業(yè)資訊頻道，感謝您對億速云的支持。