• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            學習、成長之路

              C++博客 :: 首頁 :: 聯系 :: 聚合  :: 管理
              16 Posts :: 0 Stories :: 27 Comments :: 0 Trackbacks

            常用鏈接

            留言簿

            我參與的團隊

            搜索

            •  

            最新評論

            閱讀排行榜

            評論排行榜

            最近做一個項目,需要記錄系統里每個進程訪問的IP及Port,然后提交到服務端進行分析,我的思路是用一個緩存文件記錄所有進程訪問網絡的信息,然后在主程序中提取記錄再提交。
            這里面涉及到多進程訪問同一個緩存文件的同步問題,于是封裝了下面這個類,自我感覺良好,拿出來和大家分享 :)

            * 使用類似于環形鏈表的機制來保證運行效率


            測試程序如下:
             1 #include "RecodeLog.cpp"
             2 #include <stdio.h>
             3 #pragma pack(1)
             4 // 測試用結構,可自定義,結構中不應該包涵指針類型
             5 typedef struct _tagTestInfo
             6 {
             7     DWORD nTest;
             8     char szTest[32];
             9 }TESTINFO, *PTESTINFO;
            10 #pragma pack()
            11 
            12 ULONG WINAPI TestThread(PVOID pParam)
            13 {
            14     TESTINFO ti; 
            15     CRecodeLog<TESTINFO> *prl = new CRecodeLog<TESTINFO>("TestRL""c:\\trl.dat"1000);
            16     for (int i = 0; i < 100; i++)
            17     {
            18         ti.nTest = i;
            19         itoa(i, ti.szTest, 10);
            20         // 可在任意進程或線程中調用該方法,不用考慮同步問題
            21         prl->AddLog(&ti);    // 寫入到緩沖文件中
            22     }
            23     delete prl;
            24     return 0;
            25 }
            26 
            27 int main(int argc, char* argv[])
            28 {
            29     // 開兩個線程,每個線程增加100條記錄
            30     HANDLE hThread, hThread2;
            31     hThread = CreateThread(NULL, NULL, TestThread, NULL, NULL, NULL);
            32     hThread2 = CreateThread(NULL, NULL, TestThread, NULL, NULL, NULL);
            33     WaitForSingleObject(hThread, INFINITE);
            34     WaitForSingleObject(hThread2, INFINITE);
            35     CloseHandle(hThread);
            36     CloseHandle(hThread2);
            37 
            38     
            39     CRecodeLog<TESTINFO> *prl = new CRecodeLog<TESTINFO>("TestRL""c:\\trl.dat"1000);
            40     TESTINFO getTi; 
            41     int ncount = 0;
            42     while (prl->GetTop(&getTi))    // 取最頂部的緩存記錄
            43     {
            44         printf("%d--%s\n", getTi.nTest, getTi.szTest);
            45         prl->DelTop();    //    刪除最頂端的緩存記錄
            46         ncount++;
            47     }
            48     printf("%d\n", ncount);
            49     delete prl;
            50 
            51     return 0;
            52 }

            從運行結果可以看到主線程讀取到的記錄是亂序的,但沒有丟失的記錄。。

            下載示例代碼/Files/sToa/TestCache.rar
            posted on 2009-08-16 13:41 sToa 閱讀(1754) 評論(1)  編輯 收藏 引用 所屬分類: VC

            Feedback

            # re: 封裝一個跨進程緩存類 2009-08-19 14:44 彩鈴
            離開的風格  回復  更多評論
              

            久久毛片一区二区| 婷婷国产天堂久久综合五月| 国产激情久久久久久熟女老人| 久久综合鬼色88久久精品综合自在自线噜噜| 国产无套内射久久久国产| 国产高潮国产高潮久久久| 香蕉久久夜色精品国产小说| 久久精品无码一区二区app| 国产成人综合久久精品红| 伊人久久精品无码av一区| 久久久国产精品网站| 成人精品一区二区久久久| 欧美午夜精品久久久久久浪潮| 日韩欧美亚洲综合久久| 久久成人影院精品777| 久久这里只有精品首页| 91精品国产综合久久四虎久久无码一级| 久久精品无码av| 精品久久香蕉国产线看观看亚洲 | 久久精品国产秦先生| 久久精品国产男包| 91精品国产91久久久久久| 亚洲综合伊人久久大杳蕉| 久久精品这里只有精99品| 99精品久久精品| 欧美va久久久噜噜噜久久| 99久久综合国产精品免费| 国产精品嫩草影院久久| 国产精品久久一区二区三区 | 久久夜色精品国产网站| 欧美国产精品久久高清| 国内精品久久久久久久97牛牛| 久久婷婷五月综合国产尤物app| 国产日产久久高清欧美一区| 狠狠色丁香婷婷久久综合五月 | 伊人久久大香线蕉av不变影院| 久久夜色撩人精品国产| 久久久WWW免费人成精品| 青青青国产成人久久111网站| 国产精品久久国产精品99盘| 国产精品久久久久久久久|