Libtask源碼解析之如何理解鎖

這篇文章主要講解了“Libtask源碼解析之如何理解鎖”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“Libtask源碼解析之如何理解鎖”吧！

成都創(chuàng)新互聯(lián)主要為客戶提供服務(wù)項(xiàng)目涵蓋了網(wǎng)頁視覺設(shè)計(jì)、VI標(biāo)志設(shè)計(jì)、全網(wǎng)營銷推廣、網(wǎng)站程序開發(fā)、HTML5響應(yīng)式重慶網(wǎng)站建設(shè)公司、移動網(wǎng)站建設(shè)、微商城、網(wǎng)站托管及企業(yè)網(wǎng)站維護(hù)、WEB系統(tǒng)開發(fā)、域名注冊、國內(nèi)外服務(wù)器租用、視頻、平面設(shè)計(jì)、SEO優(yōu)化排名。設(shè)計(jì)、前端、后端三個建站步驟的完善服務(wù)體系。一人跟蹤測試的建站服務(wù)標(biāo)準(zhǔn)。已經(jīng)為成都PVC花箱行業(yè)客戶提供了網(wǎng)站設(shè)計(jì)服務(wù)。

libtask中其實(shí)不需要鎖，因?yàn)閘ibtask中協(xié)程是非搶占式的，不存在競態(tài)條件。但是libtask還是實(shí)現(xiàn)了一套鎖的機(jī)制。我們看一下這個鎖機(jī)制的實(shí)現(xiàn)。首先我們看一下結(jié)構(gòu)體。

struct QLock {     // 鎖持有者     Task    *owner;     // 等待該鎖的隊(duì)列     Tasklist waiting; };

接著我們看一下鎖的操作。

加鎖

static int _qlock(QLock *l, int block) {         // 鎖沒有持有者，則置當(dāng)前協(xié)程為持有者，直接返回，1表示加鎖成功     if(l->owner == nil){         l->owner = taskrunning;         return 1;     }     // 非阻塞，則直接返回，0表示加鎖失敗     if(!block)         return 0;     // 插入等待鎖隊(duì)列     addtask(&l->waiting, taskrunning);     taskstate("qlock");     // 切換到其他協(xié)程     taskswitch();     // 切換回來時(shí)，如果持有鎖的協(xié)程不是當(dāng)前協(xié)程，則異常退出，因?yàn)橹挥谐钟墟i才會被切換回來，見unqlock     if(l->owner != taskrunning){         fprint(2, "qlock: owner=%p self=%p oops\n", l->owner, taskrunning);         abort();     }     return 1; }

如果當(dāng)前鎖沒有持有者，則當(dāng)前協(xié)程X就變成鎖的持有者，否則把協(xié)程X插入等待鎖隊(duì)列中，然后讓出cpu，切換到其他協(xié)程。當(dāng)后續(xù)鎖被釋放并被協(xié)程X持有時(shí)，協(xié)程X就會被喚醒繼續(xù)持續(xù)。加鎖可以分為阻塞和非阻塞兩種模式。非阻塞就是加鎖失敗也不會切換協(xié)程。

// 阻塞式加鎖 void qlock(QLock *l) {     _qlock(l, 1); }  // 非阻塞式加鎖 int canqlock(QLock *l) {     return _qlock(l, 0); }

釋放鎖

接下來我們看一下釋放鎖的邏輯

// 釋放鎖 void qunlock(QLock *l) {     Task *ready;     // 鎖并沒有持有者，異常退出     if(l->owner == 0){         fprint(2, "qunlock: owner=0\n");         abort();     }     // 如果還有協(xié)程在等待該鎖，則置為持有者，并且從等待隊(duì)列中刪除，然后修改狀態(tài)為就緒并加入就緒隊(duì)列     if((l->owner = ready = l->waiting.head) != nil){         deltask(&l->waiting, ready);         taskready(ready);     } }

當(dāng)鎖被釋放時(shí)，如果還有協(xié)程在等待該鎖，則從等待隊(duì)列中摘取一個節(jié)點(diǎn)，然后變成鎖的持有者并從等待隊(duì)列中刪除。最后插入就緒隊(duì)列等待調(diào)度。以上是一種互斥鎖的實(shí)現(xiàn)。下面我們再來看一下讀寫鎖機(jī)制，讀寫鎖也是互斥的，但是在某些情況下也可以共享。我們看一下讀寫鎖的數(shù)據(jù)結(jié)構(gòu)。

struct RWLock {     // 正在讀的讀者個數(shù)     int    readers;     // 當(dāng)前正在寫的寫者，只有一個     Task    *writer;     // 等待讀和寫的隊(duì)列     Tasklist rwaiting;     Tasklist wwaiting; };

接著我看一下加鎖邏輯。

加讀鎖

// 加讀鎖 static int _rlock(RWLock *l, int block) {         /*         沒有正在寫并且沒有等待寫，則加鎖成功，并且讀者數(shù)加一     */     if(l->writer == nil && l->wwaiting.head == nil){         l->readers++;         return 1;     }     // 非阻塞則直接返回     if(!block)         return 0;     // 插入等待讀隊(duì)列     addtask(&l->rwaiting, taskrunning);     taskstate("rlock");     // 切換上下文     taskswitch();     // 切換回來了，說明加鎖成功     return 1; }

當(dāng)且僅當(dāng)沒有正在寫的寫者和等待寫的寫者時(shí)，才能加讀鎖成功，否則根據(jù)加鎖模式進(jìn)行下一步處理，直接返回加鎖失敗或者插入等待隊(duì)列，然后切換到其他協(xié)程。我們看到當(dāng)有一個等待寫的協(xié)程時(shí)(l->wwaiting.head  != nil)，則后續(xù)的讀者就無法加鎖成功，而是被插入等待隊(duì)列，否則可能會引起寫者饑餓。

加寫鎖

// 加寫鎖 static int _wlock(RWLock *l, int block) {         // 沒有正在寫并且沒有正在讀，則加鎖成功，并置寫者為當(dāng)前協(xié)程     if(l->writer == nil && l->readers == 0){         l->writer = taskrunning;         return 1;     }     // 非阻塞則直接返回     if(!block)         return 0;     // 加入等待寫隊(duì)列     addtask(&l->wwaiting, taskrunning);     taskstate("wlock");     // 切換     taskswitch();     // 切換回來說明拿到鎖了     return 1; }

當(dāng)且僅當(dāng)沒有正在寫的寫者和沒有正在讀的讀者時(shí)，才能加寫鎖成功。否則類似加讀鎖一樣處理。

釋放讀鎖

// 釋放讀鎖 void runlock(RWLock *l) {     Task *t;     // 讀者減一，如果等于0并且有等待寫的協(xié)程，則隊(duì)列第一個協(xié)程持有該鎖     if(--l->readers == 0 && (t = l->wwaiting.head) != nil){         deltask(&l->wwaiting, t);         l->writer = t;         taskready(t);     } }

持有讀鎖，說明當(dāng)前肯定沒有正在寫的寫者，但是可能有等待寫的寫者和等待讀的讀者(因?yàn)橛械却龑懙膶懻邔?dǎo)致無法加鎖成功)。當(dāng)釋放讀鎖時(shí)，如果還有其他讀者，則其他讀者可以繼續(xù)持有鎖，因?yàn)樽x者可以共享讀鎖，而寫者保持原來狀態(tài)。如果這時(shí)候沒有讀者但是有等待寫的寫者，則從隊(duì)列中選擇第一個節(jié)點(diǎn)成為鎖的持有者，其他的寫者則繼續(xù)等待，因?yàn)閷懻卟荒芄蚕韺戞i。

釋放寫鎖

// 釋放寫鎖 void wunlock(RWLock *l) {     Task *t;     // 沒有正在寫，異常退出     if(l->writer == nil){         fprint(2, "wunlock: not locked\n");         abort();     }     // 置空，沒有協(xié)程正在寫     l->writer = nil;     // 有正在讀，異常退出，寫的時(shí)候，是無法讀的     if(l->readers != 0){         fprint(2, "wunlock: readers\n");         abort();     }     // 釋放寫鎖時(shí)，優(yōu)先讓讀者持有鎖，因?yàn)樽x者可以共享持有鎖，提高并發(fā)     // 讀可以共享，把等待讀的協(xié)程都加入就緒隊(duì)列，并持有鎖     while((t = l->rwaiting.head) != nil){         deltask(&l->rwaiting, t);         l->readers++;         taskready(t);     }     // 釋放寫鎖時(shí)，如果又沒有讀者，并且有等待寫的協(xié)程，則隊(duì)列的第一個等待寫的協(xié)程持有鎖     if(l->readers == 0 && (t = l->wwaiting.head) != nil){         deltask(&l->wwaiting, t);         l->writer = t;         taskready(t);     } }

持有寫鎖，可能有等待寫的寫者和等待讀的讀者。這里是讀者優(yōu)先持有鎖，因?yàn)樽x者可以共享持有鎖，提高并發(fā)，如果沒有讀者，則再判斷寫者。

感謝各位的閱讀，以上就是“Libtask源碼解析之如何理解鎖”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對Libtask源碼解析之如何理解鎖這一問題有了更深刻的體會，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點(diǎn)的文章，歡迎關(guān)注！

當(dāng)前文章：Libtask源碼解析之如何理解鎖
文章地址：http://muchs.cn/article12/ipjhdc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站內(nèi)鏈、服務(wù)器托管、網(wǎng)站維護(hù)、響應(yīng)式網(wǎng)站、品牌網(wǎng)站設(shè)計(jì)、面包屑導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)