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

            牽著老婆滿街逛

            嚴(yán)以律己,寬以待人. 三思而后行.
            GMail/GTalk: yanglinbo#google.com;
            MSN/Email: tx7do#yahoo.com.cn;
            QQ: 3 0 3 3 9 6 9 2 0 .

            libjingle翻譯之《Important Concepts(重要概念)之Threads(線程)》

            轉(zhuǎn)載自:http://blog.csdn.net/night_cat/article/details/3496797

            Threads(線程)

             

            libjingle 考慮到使用到此庫的應(yīng)用程序的性能,libjingle內(nèi)部支持多線程。其內(nèi)組件使用12個全局線程:

             signaling thread  被用作創(chuàng)建底層(基礎(chǔ))組件,

                例如:Session Management,Control,XMPP Messaging組件。

             worker thread  ( 有時稱作channel thread)用來集中處理p2p組件中的對象提交過來的大量資源,例如:數(shù)據(jù)流。之所以這樣用另外的線程單獨處理,是為了避免數(shù)據(jù)流阻塞或被XMPP/用戶界面組件阻塞。使用 worker thread的類包括ChannelManage,SocketMonitor,P2PTransportChannel 和 屬于Port類的對象。

            若起用worker thread,使之工作,在應(yīng)用中必須創(chuàng)建一個Thread類對象,并把此對象當(dāng)作SessionManager的構(gòu)造函數(shù)的參數(shù)。(如果SessionManager類對象在創(chuàng)建時,沒有傳遞給它Thread對象,則SessionManager類將在內(nèi)部創(chuàng)建一個線程,當(dāng)作worker thread)。CallClient::InitPhone示范了如何為底層組件(low-level components)創(chuàng)建一個worker thread方法。

             

            另外、libjingle提供了一個基類SignalThread。擴展此類可以讓一個擴展類對象存在于它自身代表的線程,此擴展類對象可以被實例化,啟動,單獨離開,結(jié)束時自釋放。更多信息請查看signalthread.h/cc。

             

            注意:盡管libjingle支持多線程,但是只有幾個函數(shù)通過呼叫方線程的驗證來支持線程安全,并且極少函數(shù)做了線程鎖定。下面的片斷示范了在函數(shù)中如何安全地呼叫線程(或線程安全地被呼叫):

            // Check that being called from the channel (e.g., worker) thread.

            ASSERT(talk_base::Thread::Current() == channel_thread_);

            channel_thread_->Clear(this);

             

            libjingle中用到的所有線程,signaling threadworker thread,其它的一些線程,都是talk_base::Thread的對象(或子類的對象)。所有的Thread對象都被ThreadManager管理,當(dāng)被請求時,ThreadManager會返回這些Thread對象。SessionManager被創(chuàng)建時通過調(diào)用ThreadManager::CurrentThread得到一個signal thread(當(dāng)無worker thread 傳遞給SessionManager構(gòu)造函數(shù)時,同時得到一個work thread)。XmppPump類把當(dāng)前線程當(dāng)作它的signal thread來用(XmppPump uses the current thread for its signaling thread)。所以,應(yīng)用程序必須為signal thread創(chuàng)建一個Thread對象(或其子類對象),并在SessionManager對象創(chuàng)建之前或在XmppPump工作之前,把此對象放進(jìn)ThreadManager的線程池里。(Signing In to a Server(登錄服務(wù)器) 有示例)有兩種方法創(chuàng)建一個Thread對象:

            AutoThread    這種方式就是libjingleThread對象包裝一個操作系統(tǒng)中的線程,并把它當(dāng)作ThreadManager線程池里的當(dāng)前線程(當(dāng)然,Thread::CurrentThread()被調(diào)用時,此線程會被提取出來)。

            Thread   這種方式將創(chuàng)建一個新線程并用Thread類包裝,比較典型就是的創(chuàng)建worker thread。使此線程發(fā)生作用,應(yīng)用程序必須新創(chuàng)建一個Thread對象,調(diào)用ThreadManager::Add()ThreadManager::SetCurrent()把它丟進(jìn)線程池里,并且調(diào)用Run()使之在阻塞狀態(tài)下運行或調(diào)用Start()使之處于監(jiān)聽狀態(tài)。

             

            線程為對象間或?qū)ο髢?nèi)部的消息溝通提供了“管道”()。例如:SocketManager可以通過其它線程向自己發(fā)送銷毀一個套接字的消息,或當(dāng)鏈接候選被產(chǎn)生時向SessionManager發(fā)送消息。Thread繼承自MessageQueue,所以Thread的對象具有了SendPost,和一些同步或異步發(fā)送消息的函數(shù)。如果要使一個對象能夠接收到MessageQueue送出的消息,那么此對象必須繼承和實現(xiàn)MessageHandlerMessageHandler定義了一個OnMessage函數(shù),此函數(shù)在MessageQueue送出消息時被調(diào)用,用來接收MessageQueue送出的消息。

             

            你可以通過任何線程向繼承自talk_base::MessageHandler的任何對象發(fā)送消息。盡管能夠做到,如果你發(fā)出的消息是為了集中處理大量的數(shù)據(jù),應(yīng)用程序應(yīng)該通過worker thread。調(diào)用SessionManager::worker_thread()可以得到worker thread的句柄。

            調(diào)用Session::Manager::signaling_thread()可以得到 signaling thrread的句柄。

             

            對象使用一個指定的線程有如下幾種方式:

                   對象要求一個線程指針作輸入?yún)?shù),并儲存這個指針。

                   對象在創(chuàng)建時取得當(dāng)前線程(構(gòu)造函數(shù)中調(diào)用ThreadManager::CurrentThread()取得),把取得的線程存進(jìn)對象內(nèi)部成員變量引用它,一般應(yīng)用于獲取特定的線程。(it can assume that the current thread when it is created (accessed byThreadManager::CurrentThread in its constructor) is a particular thread and cache a member pointer to it

                   對象調(diào)用SessionManger::signal_thread()  SessionManager::worker_thread()獲取線程。

                   以上三種方法,libjingle均有用到。

             

            因為一個對象可以被任意線程使用,對象可能需要驗證當(dāng)前調(diào)用是來自哪個線程的方法。應(yīng)用可以調(diào)用Thread::Current()得到當(dāng)前線程的句柄,然后與對象內(nèi)部保存線程的數(shù)據(jù)成員進(jìn)行比較,此數(shù)據(jù)成員的值可以是從SessionManager中暴露在外面的線程,或是對象在創(chuàng)建時通過構(gòu)造函數(shù)傳進(jìn)去的初始化值。

            這是一個對象通過其它線程調(diào)用自身函數(shù)時而廣范使用的范例:

            // Note that worker_thread_ is not initialized until someone 
            // calls PseudoTcpChannel::Connect
            // Also note that this method *is* thread-safe. 
            bool PseudoTcpChannel::Connect(const std::string& channel_name) {
              ASSERT(signal_thread_->IsCurrent());
              CritScope lock(&cs_);
                if (channel_)
                  return false;
                ASSERT(session_ != NULL);
                worker_thread_ = session_->session_manager()->worker_thread();
            ...
            }
             
            void PseudoTcpChannel::SomeFunction(){
              ...
              // Post a message to yourself over the worker thread.
              worker_thread_->Post(this, MSG_PING); // <- Goes in here....
              ...
            }
             
            // Handle queued requests.
            void PseudoTcpChannel::OnMessage(Message *pmsg) {
              if (pmsg->message_id == MSG_SORT)
                OnSort();
              else if (pmsg->message_id == MSG_PING) // -> And comes out here!
                // Check that we're in the worker thread before proceding.
                ASSERT(worker_thread_->IsCurrent());
                OnPing();
              else if (pmsg->message_id == MSG_ALLOCATE)
                OnAllocate();
              else
                assert(false);
            }



            posted on 2013-09-01 16:29 楊粼波 閱讀(488) 評論(0)  編輯 收藏 引用

            26uuu久久五月天| 国产69精品久久久久久人妻精品| 激情五月综合综合久久69| 97久久精品人人澡人人爽| 久久这里只精品国产99热| 久久综合色老色| 97久久国产亚洲精品超碰热| 一本久久久久久久| 午夜视频久久久久一区| 久久综合噜噜激激的五月天| 久久精品国产免费| 久久99亚洲网美利坚合众国| 人人妻久久人人澡人人爽人人精品 | 久久精品国产AV一区二区三区| 久久天天躁狠狠躁夜夜avapp| 久久精品国产精品亚洲精品| 99久久免费国产精品特黄| 亚洲午夜精品久久久久久人妖| 亚洲午夜久久久| 亚洲国产成人久久一区久久| 久久久久久国产精品免费无码| 亚洲AV无码1区2区久久| 亚洲午夜久久久影院| 久久久无码精品午夜| 久久久久97国产精华液好用吗| 久久亚洲天堂| 国内精品欧美久久精品| 精品蜜臀久久久久99网站| 久久久无码精品亚洲日韩蜜臀浪潮| 香蕉99久久国产综合精品宅男自 | 久久妇女高潮几次MBA| 久久久久婷婷| 999久久久免费国产精品播放| 久久精品国产亚洲AV无码娇色| 欧美成a人片免费看久久| 狠狠色丁香婷婷综合久久来来去 | 久久66热人妻偷产精品9| 亚洲国产精品久久久天堂 | 欧美久久久久久| 精品多毛少妇人妻AV免费久久 | 久久99国内精品自在现线|