• <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>

            ACE中ACE_Message_Block的緩存處理 - 續篇

            前面寫了幾篇文章了,最后的目的之一就是為了緩存ACE_Message_Block,代碼簡單,應該比先前的(《ACE中ACE_Message_Block的緩存處理》)實現要好,先前在使用不當的情況下會有問題的,如clone

            // MessageBlockManager.h
            /**
             *    @date 2007.10.28
             *  @author PeakGao <peakgao163@163.com>
             
            */

            #ifndef OM_MESSAGEBLOCKMANAGER_H
            #define OM_MESSAGEBLOCKMANAGER_H

            #include 
            <ace/thread_mutex.h>
            #include 
            <ace/synch_traits.h>
            #include 
            <ace/message_block.h>
            #include 
            <ace/Lock_Adapter_T.h>

            #include 
            "MemPoolT.h"
            #include 
            "MemPoolAllocator.h"

            namespace om{

                
            class MessageBlockManager
                
            {
                    typedef ACE_Lock_Adapter
            <ACE_SYNCH_MUTEX> MyLock;

                    My_Allocator    mDataPool;    
            /// 為數據緩沖分配
                    My_Allocator    mDBPool;    /// 為ACE_Data_Block對象本身分配
                    My_Allocator    mMBPool;    /// 為ACE_Message_Block對象本身分配
                    MyLock            mLock;        /// 同步鎖

                
            public:
                    
            static MessageBlockManager* instance();

                    MessageBlockManager();
                    
            ~MessageBlockManager();

                    
            /// 初始化參數
                    void create(size_t bufSize, size_t growObjCount);

                    
            /// 清除緩沖池
                    void clear();

                    
            /// 分配一個消息塊
                    ACE_Message_Block* alloc();

                    
            /// 釋放指定的消息塊
                    void free(ACE_Message_Block* mb);
                }
            ;

            }
             // namespace om

            #endif // OM_MESSAGEBLOCKMANAGER_H

            // MessageBlockManager.cpp
            /**
             *    @date 2007.10.28
             *  @author PeakGao <peakgao163@163.com>
             
            */

             
            #include 
            "MessageBlockManager.h"

            namespace om{

                
                MessageBlockManager
            * MessageBlockManager::instance()
                
            {
                    
            static MessageBlockManager* mbm = 0;
                    
            if (mbm == 0)
                        mbm 
            = new MessageBlockManager();
                    
            return mbm;
                }


                MessageBlockManager::MessageBlockManager()
                
            {
                }


                MessageBlockManager::
            ~MessageBlockManager()
                
            {
                    clear();
                }


                
            void MessageBlockManager::clear()
                
            {
                    ACE_GUARD(MyLock, ace_mon, mLock);

                    mDataPool.clear();
                    mDBPool.clear();
                    mMBPool.clear();
                }


                
            void MessageBlockManager::create(size_t bufSize, size_t growObjCount)
                
            {
                    mDataPool.create(bufSize, growObjCount);
                    mDBPool.create(
            sizeof(ACE_Data_Block), growObjCount);
                    mMBPool.create(
            sizeof(ACE_Message_Block), growObjCount);
                }


                ACE_Message_Block
            * MessageBlockManager::alloc()
                
            {
                    ACE_GUARD_RETURN(MyLock, ace_mon, mLock, NULL);

                    
            void* mb_buf = mMBPool.alloc();
                    size_t data_size 
            = mDataPool.getBlockSize();

                    
            // 直接調用構造
                    ACE_Message_Block* mb = ::new (mb_buf) ACE_Message_Block(
                                                            data_size,  
            // size
                                                            ACE_Message_Block::MB_DATA,    // type
                                                            0,            // cont
                                                            0,            // data
                                                            &mDataPool, // allocator_strategy
                                                            0// locking_strategy 我們的mLock不要傳入,因為前面有mMBPool.alloc()方法需要加鎖
                                                            ACE_DEFAULT_MESSAGE_BLOCK_PRIORITY, // priority
                                                            ACE_Time_Value::zero,        // execution_time
                                                            ACE_Time_Value::max_time,    // deadline_time
                                                            &mDBPool,    // data_block_allocator
                                                            &mMBPool    // message_block_allocator
                                                        );

                    
            return mb;
                }


                
            void MessageBlockManager::free(ACE_Message_Block* mb)
                
            {
                    ACE_GUARD(MyLock, ace_mon, mLock);

                    mb
            ->release();
                }



            }
             // namespace om

            演示代碼:
            void test()
            {
                
            using namespace om;

                MessageBlockManager::instance()
            ->create(1024256);
                ACE_Message_Block
            * mb = MessageBlockManager::instance()->alloc();
                mb
            ->copy("1234567890"11);
                assert(strcmp(mb
            ->base(), "1234567890"== 0);
                ACE_Message_Block
            * mb_clone = mb->clone();
                MessageBlockManager::instance()
            ->free(mb);
                MessageBlockManager::instance()
            ->free(mb_clone);
                MessageBlockManager::instance()
            ->clear();
            }

            如果直接為ACE_Message_Block實現對象的new/delete操作,可能用起來更方便,大家可以試試,這里我不改了。

            posted on 2007-10-29 12:57 PeakGao 閱讀(2574) 評論(0)  編輯 收藏 引用 所屬分類: C++技術

            <2007年9月>
            2627282930311
            2345678
            9101112131415
            16171819202122
            23242526272829
            30123456

            導航

            統計

            常用鏈接

            留言簿(9)

            隨筆分類(67)

            隨筆檔案(65)

            搜索

            最新評論

            閱讀排行榜

            評論排行榜

            青青草原综合久久大伊人| 狠狠色婷婷综合天天久久丁香 | 国产成人无码久久久精品一| 日韩人妻无码精品久久久不卡 | 波多野结衣久久一区二区| 无码国内精品久久人妻蜜桃| 久久国产精品一国产精品金尊| 久久夜色tv网站| 精品久久久久久国产| 精品一久久香蕉国产线看播放| AV无码久久久久不卡蜜桃| 国产一久久香蕉国产线看观看| 免费精品国产日韩热久久| 精品久久久久久无码专区不卡| 色偷偷91久久综合噜噜噜噜| 久久精品国产亚洲av影院| 亚洲色欲久久久久综合网| 久久不见久久见免费视频7| 午夜精品久久久久9999高清| 久久精品一区二区| 久久91精品国产91| 久久九九久精品国产免费直播| 精品久久无码中文字幕| A级毛片无码久久精品免费| 久久嫩草影院免费看夜色| 国产高清美女一级a毛片久久w | 国产伊人久久| 国产精品久久久久影院嫩草| 亚洲人成网亚洲欧洲无码久久| 久久亚洲国产成人影院| 性做久久久久久久久老女人 | 免费一级做a爰片久久毛片潮| 99久久精品免费看国产免费| 99麻豆久久久国产精品免费| 人妻无码αv中文字幕久久琪琪布| 狠狠色婷婷久久综合频道日韩| 午夜精品久久久久| 亚洲国产精品久久电影欧美| 久久无码高潮喷水| 久久无码人妻一区二区三区| 国产精品免费看久久久|