libuv queue的實現(xiàn)

最近看node源碼的時候注意到libuv中的一個隊列實現(xiàn)浙值,是c風格的宵睦,也是linux內核中常見的寫法,因為一直使用c++的隊列次泽,所以對這種寫法看不太懂穿仪,經(jīng)過向牛人請教,終于明白了其中奧妙意荤。

先一窺芳容:

#ifndef QUEUE_H_
#define QUEUE_H_

typedef void *QUEUE[2];

/* Private macros. */
#define QUEUE_NEXT(q)       (*(QUEUE **) &((*(q))[0]))
#define QUEUE_PREV(q)       (*(QUEUE **) &((*(q))[1]))
#define QUEUE_PREV_NEXT(q)  (QUEUE_NEXT(QUEUE_PREV(q)))
#define QUEUE_NEXT_PREV(q)  (QUEUE_PREV(QUEUE_NEXT(q)))

/* Public macros. */
#define QUEUE_DATA(ptr, type, field)                                          \
  ((type *) ((char *) (ptr) - ((char *) &((type *) 0)->field)))

#define QUEUE_FOREACH(q, h)                                                   \
  for ((q) = QUEUE_NEXT(h); (q) != (h); (q) = QUEUE_NEXT(q))

#define QUEUE_EMPTY(q)                                                        \
  ((const QUEUE *) (q) == (const QUEUE *) QUEUE_NEXT(q))

#define QUEUE_HEAD(q)                                                         \
  (QUEUE_NEXT(q))

#define QUEUE_INIT(q)                                                         \
  do {                                                                        \
    QUEUE_NEXT(q) = (q);                                                      \
    QUEUE_PREV(q) = (q);                                                      \
  }                                                                           \
  while (0)

#define QUEUE_ADD(h, n)                                                       \
  do {                                                                        \
    QUEUE_PREV_NEXT(h) = QUEUE_NEXT(n);                                       \
    QUEUE_NEXT_PREV(n) = QUEUE_PREV(h);                                       \
    QUEUE_PREV(h) = QUEUE_PREV(n);                                            \
    QUEUE_PREV_NEXT(h) = (h);                                                 \
  }                                                                           \
  while (0)

#define QUEUE_SPLIT(h, q, n)                                                  \
  do {                                                                        \
    QUEUE_PREV(n) = QUEUE_PREV(h);                                            \
    QUEUE_PREV_NEXT(n) = (n);                                                 \
    QUEUE_NEXT(n) = (q);                                                      \
    QUEUE_PREV(h) = QUEUE_PREV(q);                                            \
    QUEUE_PREV_NEXT(h) = (h);                                                 \
    QUEUE_PREV(q) = (n);                                                      \
  }                                                                           \
  while (0)

#define QUEUE_INSERT_HEAD(h, q)                                               \
  do {                                                                        \
    QUEUE_NEXT(q) = QUEUE_NEXT(h);                                            \
    QUEUE_PREV(q) = (h);                                                      \
    QUEUE_NEXT_PREV(q) = (q);                                                 \
    QUEUE_NEXT(h) = (q);                                                      \
  }                                                                           \
  while (0)

#define QUEUE_INSERT_TAIL(h, q)                                               \
  do {                                                                        \
    QUEUE_NEXT(q) = (h);                                                      \
    QUEUE_PREV(q) = QUEUE_PREV(h);                                            \
    QUEUE_PREV_NEXT(q) = (q);                                                 \
    QUEUE_PREV(h) = (q);                                                      \
  }                                                                           \
  while (0)

#define QUEUE_REMOVE(q)                                                       \
  do {                                                                        \
    QUEUE_PREV_NEXT(q) = QUEUE_NEXT(q);                                       \
    QUEUE_NEXT_PREV(q) = QUEUE_PREV(q);                                       \
  }                                                                           \
  while (0)

#endif /* QUEUE_H_ */

第一次看到全部用宏來寫的隊列啊片,看起來也沒多少代碼,真的能實現(xiàn)雙向循環(huán)鏈表嗎玖像?而且數(shù)據(jù)存在哪里呢? 和c++還是有很大區(qū)別的啊紫谷,沒有類,也沒有模板捐寥。沒有object這樣的基類笤昨。源碼可以在這里找到:https://github.com/libuv/libuv


關鍵點講解

** 1. 定義指針數(shù)組類型**

typedef void *QUEUE[2];

后面就可以這樣定義一個void*的數(shù)組了

/**
* A pointer to a list node.
*/
QUEUE* q;

** 2. 定義基本操作 **

#define QUEUE_NEXT(q)       (*(QUEUE **) &((*(q))[0]))
#define QUEUE_PREV(q)       (*(QUEUE **) &((*(q))[1]))

數(shù)組的第0個表示下一個,1表示上一個握恳。
這里使用(*(QUEUE **) &((*(q))[0]))這么復雜的表達是有兩個原因瞒窒。一個是轉成左值,另一個是保存類型信息乡洼。

這樣會丟失類型信息
#define QUEUE_NEXT(q)          ((*(q))[0]) 

這樣不是左值
#define QUEUE_PREV(q)       ((QUEUE *) ((*(q))[1]))

** 3. 取值 **
這個隊列的實現(xiàn)和數(shù)據(jù)無關崇裁,所以宏里面看不到data的定義,是不是很神奇束昵,像在c++這種面向對象的語言中寇壳,我們一般通過迭代器來實現(xiàn)操作和數(shù)據(jù)的分離,而c語言可以用很巧妙的方式去高效的實現(xiàn)哦妻怎。

#define QUEUE_DATA(ptr, type, field)                                          \
  ((type *) ((char *) (ptr) - ((char *) &((type *) 0)->field)))

((char *) &((type *) 0)->field))是拿到偏移量壳炎。為什么這樣就可以拿到偏移量?其實很好理解逼侦,把0當做其實地址匿辩,取field的地址,就是偏移量啦榛丢。

我們先簡單看一下如何使用這個QUEUE_DATA

    /**
    * Retrieve a pointer to our first user john.
    */
    q = QUEUE_HEAD(&queue);
    //q = ((*(&queue))[0]) ;
    /**
    * Should retrieve the user behind the "q" pointer.
    */
    user = QUEUE_DATA(q, struct user_s, node);

    /**
    * Should output the name of john.
    */
    printf("Received first inserted user: %s who is %d.\n",
        user->name, user->age);

現(xiàn)在不用仔細看铲球,后面會把例子都貼出來。只要知道屬性name晰赞,age怎么拿到就好稼病。

4. 隊列操作
我們通過上面的代碼,可以知道隊列的操作是通過宏定義的掖鱼,宏的名稱已經(jīng)很容易看懂啦然走,所以這里不仔細過了。


例子

例子加上上面難點的講解戏挡,應該能說的清楚了芍瑞。

#include "queue.h"
#include <stdio.h>

/**
* A pointer to a list node.
*/
static QUEUE* q;

/**
* Our circulary list.
*/
static QUEUE queue;

/**
* Our item struct we want to store in queue.
*/
struct user_s {
    int age;
    char* name;

    QUEUE node;
};

int main() {
    /**
    * This will be our user pointer.
    * It will point to the user we received from the queue.
    */
    struct user_s* user;

    /**
    * John is 44.
    */
    struct user_s john;
    john.name = "john";
    john.age = 44;


    /**
    * Henry is 32.
    */
    struct user_s henry;
    henry.name = "henry";
    henry.age = 32;

    /**
    * Willy is 99.
    */
    struct user_s willy;
    willy.name = "willy";
    willy.age = 99;

    /**
    * Initialize the queue of each user.
    */
    QUEUE_INIT(&queue);
    QUEUE_INIT(&john.node);
    QUEUE_INIT(&henry.node);
    QUEUE_INIT(&willy.node);

    ((*(&queue))[0]) = john.node;
    (*(QUEUE **) &((*(&queue))[0])) = &john.node;
    /**
    * Lets insert each user to the tail of the list.
    */
    QUEUE_INSERT_TAIL(&queue, &john.node);
    QUEUE_INSERT_TAIL(&queue, &henry.node);
    QUEUE_INSERT_TAIL(&queue, &willy.node);

    /**
    * Retrieve a pointer to our first user john.
    */
    q = QUEUE_HEAD(&queue);
    //q = ((*(&queue))[0]) ;
    /**
    * Should retrieve the user behind the "q" pointer.
    */
    user = QUEUE_DATA(q, struct user_s, node);

    /**
    * Should output the name of john.
    */
    printf("Received first inserted user: %s who is %d.\n",
        user->name, user->age);

    /**
    * Now lets remove john from the queue.
    */
    QUEUE_REMOVE(q);

    /**
    * Lets output the other two users through a for each loop.
    */
    QUEUE_FOREACH(q, &queue) {
        user = QUEUE_DATA(q, struct user_s, node);

        printf("Received rest inserted users: %s who is %d.\n",
            user->name, user->age);
    }

    return 0;
}
  1. 如何拿出數(shù)據(jù)的
user = QUEUE_DATA(q, struct user_s, node);

實際上是用q的地址減去8
注意q實際上是&john.node

找到首地址

  1. 環(huán)形雙向鏈表圖
    上個手抄本,么么噠褐墅。
手抄本

總結

有時間還想把C++拆檬,C#和JS如何實現(xiàn)隊列拿出來比較比較洪己,實際上算法的思想應該是一樣的,只是有的性能高竟贯,有的代碼易讀性好答捕,代碼少。哈哈屑那,由于c語言一直處在浩強老濕那本書的水平拱镐,所以今天看到這個實現(xiàn)還是覺得很爽。齐莲。痢站。

最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市选酗,隨后出現(xiàn)的幾起案子阵难,更是在濱河造成了極大的恐慌,老刑警劉巖芒填,帶你破解...
    沈念sama閱讀 212,542評論 6 493
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件呜叫,死亡現(xiàn)場離奇詭異,居然都是意外死亡殿衰,警方通過查閱死者的電腦和手機朱庆,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,596評論 3 385
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來闷祥,“玉大人娱颊,你說我怎么就攤上這事】常” “怎么了箱硕?”我有些...
    開封第一講書人閱讀 158,021評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長悟衩。 經(jīng)常有香客問我剧罩,道長,這世上最難降的妖魔是什么座泳? 我笑而不...
    開封第一講書人閱讀 56,682評論 1 284
  • 正文 為了忘掉前任惠昔,我火速辦了婚禮,結果婚禮上挑势,老公的妹妹穿的比我還像新娘镇防。我一直安慰自己,他們只是感情好薛耻,可當我...
    茶點故事閱讀 65,792評論 6 386
  • 文/花漫 我一把揭開白布营罢。 她就那樣靜靜地躺著,像睡著了一般饼齿。 火紅的嫁衣襯著肌膚如雪饲漾。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,985評論 1 291
  • 那天缕溉,我揣著相機與錄音考传,去河邊找鬼。 笑死证鸥,一個胖子當著我的面吹牛僚楞,可吹牛的內容都是我干的。 我是一名探鬼主播枉层,決...
    沈念sama閱讀 39,107評論 3 410
  • 文/蒼蘭香墨 我猛地睜開眼泉褐,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了鸟蜡?” 一聲冷哼從身側響起膜赃,我...
    開封第一講書人閱讀 37,845評論 0 268
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎揉忘,沒想到半個月后跳座,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,299評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡泣矛,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 36,612評論 2 327
  • 正文 我和宋清朗相戀三年疲眷,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片您朽。...
    茶點故事閱讀 38,747評論 1 341
  • 序言:一個原本活蹦亂跳的男人離奇死亡狂丝,死狀恐怖,靈堂內的尸體忽然破棺而出哗总,到底是詐尸還是另有隱情几颜,我是刑警寧澤,帶...
    沈念sama閱讀 34,441評論 4 333
  • 正文 年R本政府宣布魂奥,位于F島的核電站菠剩,受9級特大地震影響,放射性物質發(fā)生泄漏耻煤。R本人自食惡果不足惜具壮,卻給世界環(huán)境...
    茶點故事閱讀 40,072評論 3 317
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望哈蝇。 院中可真熱鬧棺妓,春花似錦、人聲如沸炮赦。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,828評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至性芬,卻和暖如春峡眶,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背植锉。 一陣腳步聲響...
    開封第一講書人閱讀 32,069評論 1 267
  • 我被黑心中介騙來泰國打工辫樱, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人俊庇。 一個月前我還...
    沈念sama閱讀 46,545評論 2 362
  • 正文 我出身青樓狮暑,卻偏偏與公主長得像,于是被迫代替她去往敵國和親辉饱。 傳聞我的和親對象是個殘疾皇子搬男,可洞房花燭夜當晚...
    茶點故事閱讀 43,658評論 2 350

推薦閱讀更多精彩內容

  • Spring Cloud為開發(fā)人員提供了快速構建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務發(fā)現(xiàn)彭沼,斷路器缔逛,智...
    卡卡羅2017閱讀 134,637評論 18 139
  • Android 自定義View的各種姿勢1 Activity的顯示之ViewRootImpl詳解 Activity...
    passiontim閱讀 171,849評論 25 707
  • iOS面試小貼士 ———————————————回答好下面的足夠了------------------------...
    不言不愛閱讀 1,970評論 0 7
  • ———————————————回答好下面的足夠了---------------------------------...
    恒愛DE問候閱讀 1,713評論 0 4
  • 我們經(jīng)常看到一句話:“時間和新歡溜腐,是忘掉過去重新開始的良藥译株。除非,時間不夠長挺益,新歡不夠好歉糜。”雖然時間如同上帝一般環(huán)...
    雨落依晴_閱讀 434評論 5 11