本文是在上一篇文章的基礎(chǔ)上Golang之并發(fā)編程一的基礎(chǔ)上的續(xù)篇,如果有興趣的話,大家可以先看看上一篇的內(nèi)容叛甫,也希望能給出建議,謝謝杨伙。
好了其监,那接下來繼續(xù)說Golang的并發(fā)編程吧。
多核并行化
在說到Golang的并行化時(shí)限匣,先看看并行和并發(fā)分別是什么吧抖苦。
并發(fā):是在單核cpu的基礎(chǔ)上,線程通過時(shí)間片或者爭奪和讓出控制權(quán)來實(shí)現(xiàn)任務(wù)的切換米死,從而實(shí)現(xiàn)多個(gè)任務(wù)的執(zhí)行锌历。表面上看就好像多個(gè)任務(wù)在“同時(shí)”進(jìn)行,而其實(shí)在某個(gè)時(shí)間點(diǎn)上峦筒,有且僅有一個(gè)任務(wù)在執(zhí)行而已究西。
并行:是指多核的CPU能讓同一個(gè)進(jìn)程內(nèi)的線程,實(shí)現(xiàn)真正意義上的同時(shí)運(yùn)行勘天,在理想情況下是不需要排隊(duì)的(實(shí)際是線程數(shù)量往往多余cpu核數(shù))怔揩。
在目前的Go編譯器中捉邢,還不能夠發(fā)揮多核cpu的優(yōu)勢,雖然通過參加goroutine可以實(shí)現(xiàn)多并發(fā)商膊,簡化并行代碼的編寫伏伐,但這些goroutine都運(yùn)行在同一個(gè)CPU核心上,在一個(gè)goroutine得到時(shí)間片執(zhí)行的時(shí)候晕拆,其他goroutine都會處于等待狀態(tài)藐翎,所以有時(shí)候的實(shí)際效率可能并沒有單線程的高。
所以在目前的Golang版本中实幕,我們可以通過設(shè)置環(huán)境變量來控制使用多少個(gè)CPU核心吝镣。
runtime.GOMAXPROCS(16)
通過設(shè)置環(huán)境變量GOMAXPROCS的cpu核數(shù),我們可以指定使用多少個(gè)cpu核心昆庇,另外末贾,我們可以通過NumCPU()的方法,來獲取當(dāng)前計(jì)算機(jī)的cpu核數(shù)整吆。
runtime.NumCPU()
出讓時(shí)間片
runtime.Gosched()
當(dāng)調(diào)用這個(gè)方法后拱撵,該goroutine的會讓出自己的時(shí)間片讓其他goroutine執(zhí)行。
需要注意的還有一點(diǎn):當(dāng)一個(gè)goroutine發(fā)生阻塞表蝙,Go會自動(dòng)地把與該goroutine處于同一系統(tǒng)線程的其他goroutines轉(zhuǎn)移到另一個(gè)系統(tǒng)線程上去拴测,以使這些goroutines不阻塞
同步
雖然使用了channel來作為通信手段,但還是可能避免不了goroutine間的共享數(shù)據(jù)府蛇,所以在golang中集索,還是提供了資源鎖的方案
同步鎖
Golang中提供了兩種鎖類型:sync.Mutex 、sync.RWMutex
Mutex:類似Java中的Lock汇跨,一個(gè)goroutine獲取鎖后其他goroutine只能夠等待务荆,無論讀寫操作。
RWMutex:類型Java中的讀寫鎖扰法,讀鎖占用時(shí)蛹含,鎖寫操作,寫鎖占用時(shí)塞颁,讀寫都鎖住浦箱。
全局唯一性操作
對于全局中只需要運(yùn)行一次的代碼,如初始化操作祠锣,golang提供了一個(gè)Once類型來保證唯一性操作
var once sync.Once
once.Do(方法名)
調(diào)用once.Do時(shí)酷窥,其他goroutine會被阻塞,知道全局唯一的once.Do()調(diào)用結(jié)束后才繼續(xù)
示例:
var a string
var once sync.Once
func setup() {
? ? a = "hello world"
}
func doprint() {
? ? once.Do(setup)
? ? print(a)
}
額外閱讀:golang線程同步WaitGroup