--------------------------------------------------------------------------------
標題: 一讀一寫情況下，無鎖環(huán)形隊列如何實現(xiàn)？
作者: 葉飛虎
日期: 2009.03.09
--------------------------------------------------------------------------------

   無鎖環(huán)形隊列的設(shè)計及示例，讀寫隊列最大的應用是：一個線程收到事件或消息后直接
加入到隊列，而處理線程讀取隊列中的事件或消息，并加以處理。在這個模式中，有一個線
程負責寫，多個處理線程讀自己的隊列并處理。雖然看起來象是一寫多讀，其實不然，針對
某一事件隊列而言，只有一個線程是寫一個線程是讀。

   環(huán)形一讀一寫隊列中，不需要擔心unsigned long溢出問題，因為溢出后自動回歸，相減
值還會保留。

  1 示例一(注：Max_Count 必須為 2 的指數(shù)，即：2, 4, 8, 16)：
  2 
  3 // 隊列尺寸
  4 #define Max_Count    4096
  5 #define Max_Mask     4095     // = Max_Count - 1
  6 
  7 // 變量
  8 void*          List[Max_Count];
  9 unsigned long  Push_Count;
 10 unsigned long  Pop_Count;
 11 
 12 // 初始化隊列
 13 void InitQueue()
 14 {
 15    Push_Count  = 0;
 16    Pop_Count   = 0;
 17    memset(List, 0, sizeof(List));
 18 }
 19 
 20 // 加入
 21 bool Push(void* AData)
 22 {
 23    if (Push_Count - Pop_Count < Max_Count)
 24    {
 25       List[Push_Count & Max_Mask] = AData;
 26       Push_Count++;
 27       return true;
 28    }
 29    else
 30       return false;
 31 }
 32 
 33 // 取出
 34 void* Pop()
 35 {
 36    // 初始化
 37    void* result = NULL;
 38 
 39    // 判斷是否為空
 40    if (Push_Count != Pop_Count)
 41    {
 42       result = List[Pop_Count & Max_Mask];
 43       Pop_Count++;
 44    }
 45 
 46    // 返回結(jié)果
 47    return result;
 48 }
 49 
 50 示例二(注：Max_Count >= 2)：
 51 
 52 // 隊列尺寸
 53 #define Max_Count    4096
 54 #define High_Index   4095     // = Max_Count - 1
 55 
 56 // 變量
 57 void*          List[Max_Count];
 58 unsigned long  Push_Count;
 59 unsigned long  Push_Index;
 60 unsigned long  Pop_Count;
 61 unsigned long  Pop_Index;
 62 
 63 // 初始化隊列
 64 void InitQueue()
 65 {
 66    Push_Count  = 0;
 67    Push_Index  = 0;
 68    Pop_Count   = 0;
 69    Pop_Index   = 0;
 70    memset(List, 0, sizeof(List));
 71 }
 72 
 73 // 加入
 74 bool Push(void* AData)
 75 {
 76    if (Push_Count - Pop_Count < Max_Count)
 77    {
 78       List[Push_Index] = AData;
 79       Push_Count++;
 80       if (Push_Index == High_Index)
 81          Push_Index = 0;
 82       else
 83          Push_Index++;
 84 
 85       return true;
 86    }
 87    else
 88       return false;
 89 }
 90 
 91 // 取出
 92 void* Pop()
 93 {
 94    // 初始化
 95    void* result = NULL;
 96 
 97    // 判斷是否為空
 98    if (Push_Count != Pop_Count)
 99    {
100       result = List[Pop_Index];
101       Pop_Count++;
102       if (Pop_Index == High_Index)
103          Pop_Index = 0;
104       else
105          Pop_Index++;
106    }
107 
108    // 返回結(jié)果
109    return result;
110 }
111