• <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 閱讀(1772) 評論(1)  編輯 收藏 引用 所屬分類: VC

            Feedback

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

            国产精品一久久香蕉国产线看观看| 久久天天躁狠狠躁夜夜2020老熟妇 | 久久久精品视频免费观看 | 久久国产亚洲高清观看| 69久久夜色精品国产69| 久久er国产精品免费观看8| 伊人久久综合成人网| 国产成人久久精品麻豆一区 | 996久久国产精品线观看| 日韩精品无码久久一区二区三| 久久久精品人妻一区二区三区四| 国产精品伊人久久伊人电影| 久久亚洲私人国产精品vA| 亚洲日本va午夜中文字幕久久 | 99蜜桃臀久久久欧美精品网站| 久久国产精品99精品国产987| 色狠狠久久综合网| 久久久久久久综合日本| 亚洲午夜久久久精品影院| 久久亚洲精精品中文字幕| 亚洲人成电影网站久久| 久久精品国产精品亜洲毛片| 国产精品久久久久久搜索| 久久婷婷国产综合精品| 久久一日本道色综合久久| 亚洲欧洲中文日韩久久AV乱码| 香蕉久久夜色精品国产小说| 精品久久久久久亚洲精品| 亚洲中文字幕无码久久2020| 国产精品久久久久a影院| 国产精品gz久久久| 99久久人人爽亚洲精品美女| 97精品伊人久久久大香线蕉 | 久久精品卫校国产小美女| 久久综合色老色| 久久91精品国产91| 久久国产劲爆AV内射—百度| 国产精品中文久久久久久久| 久久久久久久久66精品片| av色综合久久天堂av色综合在| 乱亲女H秽乱长久久久|