Go語(yǔ)言——sync.Map詳解

sync.Map是1.9才推薦的并發(fā)安全的map，除了互斥量以外，還運(yùn)用了原子操作，所以在這之前，有必要了解下 Go語(yǔ)言——原子操作

成都創(chuàng)新互聯(lián)長(zhǎng)期為1000多家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開(kāi)放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為雙橋企業(yè)提供專業(yè)的成都網(wǎng)站制作、網(wǎng)站建設(shè)，雙橋網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開(kāi)發(fā)。

go1.10\src\sync\map.go

entry分為三種情況：

從read中讀取key，如果key存在就tryStore。

注意這里開(kāi)始需要加鎖，因?yàn)樾枰僮鱠irty。

條目在read中，首先取消標(biāo)記，然后將條目保存到dirty里。（因?yàn)闃?biāo)記的數(shù)據(jù)不在dirty里）

最后原子保存value到條目里面，這里注意read和dirty都有條目。

總結(jié)一下Store：

這里可以看到dirty保存了數(shù)據(jù)的修改，除非可以直接原子更新read，繼續(xù)保持read clean。

有了之前的經(jīng)驗(yàn)，可以猜測(cè)下load流程：

與猜測(cè)的 區(qū)別 ：

由于數(shù)據(jù)保存兩份，所以刪除考慮：

先看第二種情況。加鎖直接刪除dirty數(shù)據(jù)。思考下貌似沒(méi)什么問(wèn)題，本身就是臟數(shù)據(jù)。

第一種和第三種情況唯一的區(qū)別就是條目是否被標(biāo)記。標(biāo)記代表刪除，所以直接返回。否則CAS操作置為nil。這里總感覺(jué)少點(diǎn)什么，因?yàn)闂l目其實(shí)還是存在的，雖然指針nil。

看了一圈貌似沒(méi)找到標(biāo)記的邏輯，因?yàn)閯h除只是將他變成nil。

之前以為這個(gè)邏輯就是簡(jiǎn)單的將為標(biāo)記的條目拷貝給dirty，現(xiàn)在看來(lái)大有文章。

p == nil，說(shuō)明條目已經(jīng)被delete了，CAS將他置為標(biāo)記刪除。然后這個(gè)條目就不會(huì)保存在dirty里面。

這里其實(shí)就跟miss邏輯串起來(lái)了，因?yàn)閙iss達(dá)到閾值之后，dirty會(huì)全量變成read，也就是說(shuō)標(biāo)記刪除在這一步最終刪除。這個(gè)還是很巧妙的。

真正的刪除邏輯：

很繞。。。。

golang多線程簡(jiǎn)單邏輯

實(shí)現(xiàn)指定個(gè)核心最大化使用，比如核心總數(shù)減一。

必要的庫(kù)。

要使用的cpu數(shù)量，建議不全使用。

建立管道。

聲明使用的cpu數(shù)。

建立互斥關(guān)系，本例中主要為了實(shí)現(xiàn)所有線程執(zhí)行完后再執(zhí)行后續(xù)程序。

創(chuàng)建cpu數(shù)減1個(gè)線程

后面每個(gè)任務(wù)結(jié)束時(shí)要done一個(gè)wg，這里根據(jù)具體情況加，是循環(huán)就在每個(gè)循環(huán)里加，保證后面能全部done即可

沒(méi)有緩沖的、阻塞式的往管道傳遞字符串。

Wait是等所有線程都執(zhí)行完，即增加的數(shù)字被全done掉。

關(guān)閉管道。

假設(shè)已有的函數(shù)是ReadLogs，在它的基礎(chǔ)上加個(gè)Wg加函數(shù)名的新函數(shù)，我覺(jué)得這種方式不改變?cè)械?，比較舒服。

大意是：循環(huán)從管道讀取字符串，讀不到了就跳出循環(huán)。

每個(gè)ReadLogs()之后加一個(gè)wg.Done()，相當(dāng)于計(jì)數(shù)減一。

ReadLogs()就是要執(zhí)行的任務(wù)，不再解釋。

就是開(kāi)指定個(gè)線程。

管道阻塞傳值。

wg同步。

WgReadLogs循環(huán)接收。

為什么不使用Go語(yǔ)言呢？

今年的早些時(shí)候我們對(duì)比過(guò)了幾種native編程語(yǔ)言，包括D語(yǔ)言、Go、Rust和Vala。這里我們將分析來(lái)自Google的Go語(yǔ)言，看看他到底哪里跟別的語(yǔ)言不一樣。 Go語(yǔ)言比其他的很多語(yǔ)言都吸引我，雖然我不是Go語(yǔ)言的專家，但是我很樂(lè)意在這里介紹一下它的特性，下面的這些特性指引我轉(zhuǎn)向了Go語(yǔ)言。 快速簡(jiǎn)單的編譯： go語(yǔ)言編譯的很快，事實(shí)上，他快的甚至可以作為腳本語(yǔ)言了。幾個(gè)使他編譯很快的原因有： 他不使用頭文件當(dāng)A依賴B，B又依賴C時(shí)，那么首先會(huì)編譯C，然后是B和A；但是如果A依賴B，但是A并不直接依賴于C，而是存在依賴傳遞，這時(shí)會(huì)把所有B需要從C拿到的信息放在B的對(duì)象代碼里。這樣，當(dāng)編譯A的時(shí)候，就不需要再管C了。在編譯程序時(shí)，只需將類型信息沿著依賴關(guān)系樹(shù)向上遍歷即可，如果到達(dá)樹(shù)的頂端，則只需編譯緊鄰的依賴，而不用管其它層級(jí)的依賴了。通過(guò)多返回值的錯(cuò)誤處理： 現(xiàn)代的編程語(yǔ)言基本上有兩種錯(cuò)誤處理辦法，例如在C語(yǔ)言里是使用返回值，而在Java等面向?qū)ο笳Z(yǔ)言里使用異常處理返回值，因?yàn)榉祷刂档臓顟B(tài)碼總是可能跟需要返回的結(jié)果有沖突。Go語(yǔ)言允許多返回值，從某種程度上解決了這個(gè)問(wèn)題。你可以為你的函數(shù)的執(zhí)行結(jié)果狀態(tài)定義返回值，任何調(diào)用的時(shí)候都可以來(lái)檢查，很方便。簡(jiǎn)單的組合： 可以使用interface為對(duì)象指定一些類型的成員，還可以像Java一樣給他們指定操作（行為）。例如在標(biāo)準(zhǔn)庫(kù)的io包中定義了一個(gè)Writer，就有一個(gè)帶有字節(jié)數(shù)組作為參數(shù)（輸入）一個(gè)integer值和錯(cuò)誤碼作為返回值（輸出）的方法。而實(shí)現(xiàn)了io.Writer接口中的Write方法的類型才是實(shí)際被執(zhí)行的。這個(gè)設(shè)計(jì)能夠非常優(yōu)雅的分離代碼，還簡(jiǎn)化了單元測(cè)試過(guò)程，例如，如果你想測(cè)試一個(gè)數(shù)據(jù)庫(kù)對(duì)象的一個(gè)方法，在傳統(tǒng)的語(yǔ)言中你必須創(chuàng)建一個(gè)數(shù)據(jù)庫(kù)對(duì)象，然后做很多協(xié)議初始化工作。在Go語(yǔ)言中，你可在接口下創(chuàng)建任何對(duì)象。簡(jiǎn)單的并發(fā)： 在Go中并發(fā)變得非常的簡(jiǎn)單，在任何函數(shù)前方上go兩個(gè)字母，這個(gè)函數(shù)就將以他自己的go-routine（一個(gè)非常輕量級(jí)的線程）來(lái)運(yùn)行，Go- routines之間通過(guò)channels來(lái)通信。我們通常會(huì)有一些需要線程同步和互斥的需求，在Go中非常簡(jiǎn)單，Go只是啟動(dòng)并發(fā)任務(wù)，各個(gè)任務(wù)之間通過(guò)channels來(lái)通信，從而協(xié)調(diào)同步和互斥。優(yōu)秀的錯(cuò)誤提示： 我從沒(méi)見(jiàn)過(guò)別的語(yǔ)言有Go語(yǔ)言這么高的錯(cuò)誤診斷質(zhì)量。例如如果你的程序思索了，Go的運(yùn)行時(shí)可以通知你，而且，他甚至可以告訴你是哪個(gè)線程出了問(wèn)題。當(dāng)然編譯錯(cuò)誤也是很詳細(xì)很有用的。其他特性：Go語(yǔ)言還有其他非常吸引人的特性：高階函數(shù)、垃圾回收、哈希映射、可擴(kuò)展的數(shù)組等等。當(dāng)然了，沒(méi)有一件東西是非常完美的，Go語(yǔ)言的開(kāi)發(fā)工具還非常缺乏，社區(qū)很小，但是這個(gè)語(yǔ)言的背后支持者是Google，這些問(wèn)題都會(huì)一步一步的解決。當(dāng)其他語(yǔ)言，尤其是D語(yǔ)言、Rust、Vala旨在簡(jiǎn)化C++而且增加新的特性的時(shí)候，他們都覺(jué)得自己像是帶著新特性的C++。