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

    
            

            




            







												


        


            


            勤能補拙，Expter
            

            成都游戲Coder，記錄游戲開發(fā)過程的筆記和心得！
            

            




            
	
					
	
            
		
            
			一個簡單線程池的實現(xiàn)
		
            
		        以前寫線程池是在網(wǎng)絡編程的時候，一個線程池處理一個網(wǎng)絡套接字，隨著連接的增多，效率很低，
                    最近主要是在封裝一個ipc程序(進程間通信機制) 主要
                涉及的技術(shù)：   
                Winsock, 線程池
                因為光是基于線程池的技術(shù)效率還是很低，打算重新把其代碼整理重新封裝通過，在此基礎上通過完成端口來封裝一個簡單的高并發(fā)服務器。
            

                可能涉及的技術(shù)
                Winsock：   windows網(wǎng)絡通信
                完成端口:   Windows上服務器的大規(guī)模連接機制。
                線程池：    高效高利用率的線程機制。
            

                    本文主要實現(xiàn)一個線程池的例子，從基本原理入手，一個線程池會記錄每個線程的信息，以及每個線程的處理。
                     一般一個簡單線程池至少包含下列組成部分。
            

                     1.線程池管理器（ThreadPoolManager）:用于創(chuàng)建并管理線程池 
                     2.工作線程（WorkThread）: 線程池中線程 
                     3.任務接口（Task）:每個任務必須實現(xiàn)的接口，以供工作線程調(diào)度任務的執(zhí)行。 
                     4.任務隊列:用于存放沒有處理的任務。提供一種緩沖機制。 
                     
                   
            

              1#pragma once
              2
              3#include "lock.h"
              4
              5/// 線程池
              6namespace tp_ipc_peer_namespace
              7{
              8    /// 接口
              9    class task_object
             10    {
             11    public:
             12        virtual ~task_object(){}
             13        virtual void exec() = 0;
             14    }            ;
             15
             16    template< typename Functor>
             17    class task 
             18        : public task_object
             19    {
             20
             21        /// 禁止操作
             22    private:
             23        task( const task &);
             24        task & operator =( const task & );
             25
             26    public:
             27        typedef Functor functor_type;
             28
             29        task( const functor_type & functor)
             30            : functor_( functor )
             31        { }
             32
             33        /// 執(zhí)行
             34        virtual void exec()
             35        {
             36            functor_();
             37        }
             38
             39    private:
             40        Functor functor_;
             41        
             42    }            ;
             43
             44    class ctpool
             45    {
             46        typedef ctpool self_type;
             47        
             48    public:
             49        ctpool(void)
             50            :tpool_running_( true )
             51        { 
             52            _m_start_threads( 1 );
             53        }
             54        ctpool ( unsigned threadsize )
             55            :tpool_running_(true)
             56        {
             57            _m_start_threads( threadsize );
             58        }
             59
             60        template< typename Function>
             61        void push( const Function & f)
             62        {
             63            /// 枷鎖
             64            task_lock_.enter();
             65
             66            task_container_.push_back( new tp_ipc_peer_namespace::task<Function>( f ) );
             67            
             68            task_lock_.leave();
             69
             70        }
             71        
             72        ~ctpool(void){}
             73
             74    private:
             75
             76        /// 創(chuàng)建線程池
             77        void _m_start_threads( unsigned size )
             78        {
             79            if ( size == 0 )
             80                size = 4;
             81
             82            for ( unsigned i = 0 ; i < size ; i++)
             83            {
             84                tinfo_type tinfo;
             85                tinfo.state = 0;
             86                tinfo.handle = (HANDLE)::_beginthreadex( 0 , 0 , _m_work_thread , NULL , NULL ,&(tinfo.tid) );
             87                threads_.push_back(  tinfo );
             88            }
             89        }
             90        
             91        /// 喚醒
             92        void _m_wakeup()
             93        {
             94            HANDLE handle = 0;
             95
             96            /// 對共享區(qū) 枷鎖
             97            tlock_.enter();
             98            std::vector<tinfo_type>::iterator it = threads_.begin(), end = threads_.end();
             99
            100            for ( ; it != end ; ++it )
            101            {
            102                if ( it->state == 0 ) /// 在等待狀態(tài)
            103                {
            104                    handle      =  it->handle ;
            105                    it->state = 1;
            106                    break;
            107                }
            108            }
            109            tlock_.leave();
            110
            111            while ( ::ResumeThread( handle ) != 1)
            112                ;
            113        }
            114
            115        /// 掛起某個線程
            116        void _m_suspend()
            117        {
            118            unsigned tid = ::GetCurrentThreadId();
            119            HANDLE   handle = 0;
            120
            121            tlock_.enter();
            122
            123            /// 對共享區(qū) 枷鎖
            124            tlock_.enter();
            125            std::vector<tinfo_type>::iterator it = threads_.begin(), end = threads_.end();
            126
            127            for ( ; it != end ; ++it )
            128            {
            129                if ( it->tid == tid ) /// 運行ID
            130                {
            131                    handle      =  it->handle ;
            132                    it->state = 0;
            133                    break;
            134                }
            135            }
            136            tlock_.leave();
            137
            138            /// 掛起
            139            if ( handle)
            140            {
            141                ::SuspendThread( handle );
            142            }
            143        }
            144
            145        /// 獲取task
            146        tp_ipc_peer_namespace::task_object * _m_read_task()
            147        {
            148            while( tpool_running_ )
            149            {
            150                tp_ipc_peer_namespace::task_object * task = NULL;
            151                
            152                /// 對共享區(qū) 枷鎖
            153                task_lock_.enter();
            154                if ( task_container_.size() )
            155                {
            156                    task = *( task_container_.begin() );
            157                    task_container_.erase( task_container_.begin() );
            158                }
            159                task_lock_.leave();
            160
            161                if ( task )
            162                {
            163                    return task;
            164                }
            165                else
            166                    _m_suspend();
            167            }
            168            return NULL;
            169        }
            170
            171    private:
            172        static  unsigned __stdcall _m_work_thread(void * arg)
            173        {
            174            
            175            self_type & self = *reinterpret_cast<self_type*>(arg);
            176            tp_ipc_peer_namespace::task_object * task = 0;
            177
            178            ::SuspendThread(::GetCurrentThread());
            179
            180            while( true )
            181            {
            182                task = self._m_read_task();
            183                if ( task )
            184                {
            185                    task->exec();
            186
            187                    delete task ;
            188                    task = 0;
            189                }
            190                else
            191                    break;
            192            }
            193            
            194            ::_endthreadex( 0 );
            195            return 0;
            196        }
            197
            198    private:
            199        /// 線程信息
            200        struct tinfo_type
            201        {
            202            HANDLE            handle;
            203            unsigned        tid;
            204            unsigned long    state;  // 0 = sleep;
            205        }            ;
            206
            207        /// user define var
            208    private:
            209        /// 線程運行狀態(tài)
            210        volatile bool                tpool_running_;
            211        /// 一個臨界區(qū)類
            212        sync::csectionlock            tlock_;                
            213        /// 線程信息
            214        std::vector<tinfo_type>        threads_;        
            215        /// 
            216        sync::csectionlock            task_lock_;
            217        /// 一個回調(diào)函數(shù)
            218        std::vector<task_object* > task_container_;
            219
            220    }            ;
            221
            222
            223}
            





                   備注:在設計ipc的時候參考  http://man.chinaunix.net/tech/lyceum/linuxK/ipc/ipc.html
                            線程池設計                  http://www.ibm.com/developerworks/cn/java/l-threadPool/
            

		
            
			posted on 2009-08-09 18:10 expter 閱讀(4198) 評論(8)  編輯 收藏 引用  
		
            
	
            
	
	





            
	    
    


            

            評論
            
	
	
			
            
				# re: 一個簡單線程池的實現(xiàn)[未登錄]
					
						2009-08-10 01:57
					
				fox
			
            
			
            
				不用線程，只是select輪詢又如何？不見得性能很差。  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2009-08-10 09:19
					
				abettor
			
            
			
            
				@fox
            select的話，如果進程同時占用的socket超過100，效率將顯著下降。
            另外select模型畢竟還是串行操作，無法做到真正的recv/send并行。  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)[未登錄]
					
						2009-08-10 17:57
					
				欲三更
			
            
			
            
				你一個線程select幾十個不就行了？  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2009-08-10 19:43
					
				expter
			
            
			
            
				@fox

            select模型 確實能提高效率，我這里只是介紹一個線程池，他是我在處理IPC機制的一個模型  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2010-02-25 14:11
					
				tcpcoder
			
            
			
            
				都是epoll的年代了，還select-_-!  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2010-04-07 23:00
					
				asuran
			
            
			
            
				如果你只需要1～2個socket 連接select 還是很不錯的， 比如客戶端

            如果需要handle大量的鏈接， 如服務器端， 用 IOCP /EPOLL/BOOST。ASIO
            所以需要case by case, 不能一概而論  回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2011-10-26 17:47
					
				wishper
			
            
			
            
				這代碼 應該不是你寫的吧.只是把人家的代碼拿來該了幾個namespace
              回復  更多評論
				  
			
            
		
			
            
				# re: 一個簡單線程池的實現(xiàn)
					
						2013-01-30 10:27
					
				clement
			
            
			
            
				這線程池寫的不咋地。能運行嗎？  回復  更多評論
				  
			
            
		

            




            






            

				

            


    
    







            
	   
	



女同久久|
亚洲AV日韩精品久久久久|
热re99久久6国产精品免费|
亚洲精品乱码久久久久久|
久久久这里有精品中文字幕|
国产99久久久久久免费看|
久久精品成人免费国产片小草|
女人高潮久久久叫人喷水|
久久精品中文字幕一区|
伊人久久久AV老熟妇色|
久久综合久久综合久久综合|
色综合久久综精品|
天天综合久久久网|
国产福利电影一区二区三区久久老子无码午夜伦不
|
国产成人精品综合久久久久|
久久久午夜精品|
久久人人爽人人人人爽AV
|
精品久久香蕉国产线看观看亚洲|
久久99热这里只有精品国产|
国内精品综合久久久40p|
久久无码AV中文出轨人妻|
久久99久久99小草精品免视看
|
久久久久久狠狠丁香|
亚洲嫩草影院久久精品|
亚洲级αV无码毛片久久精品|
97精品国产97久久久久久免费|
狠狠综合久久综合88亚洲|
久久久免费精品re6|
久久久久久亚洲精品影院|
亚洲中文字幕无码久久精品1
|
99久久无码一区人妻|
欧美午夜A∨大片久久
|
久久久精品人妻一区二区三区蜜桃
|
国产精品无码久久综合|
久久婷婷人人澡人人爽人人爱|
亚洲午夜久久久久妓女影院|
久久久久久人妻无码|
久久国产香蕉一区精品|
国产成人精品久久|
四虎国产精品免费久久久|
久久99国产精品久久99小说|