Threads（線程）
libjingle 考慮到使用到此庫的應(yīng)用程序的性能，libjingle內(nèi)部支持多線程。其內(nèi)組件使用1或2個全局線程：
● 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。擴(kuò)展此類可以讓一個擴(kuò)展類對象存在于它自身代表的線程，此擴(kuò)展類對象可以被實例化，啟動，單獨離開，結(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 thread，worker 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 這種方式就是libjingle用Thread對象包裝一個操作系統(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的對象具有了Send，Post，和一些同步或異步發(fā)送消息的函數(shù)。如果要使一個對象能夠接收到MessageQueue送出的消息，那么此對象必須繼承和實現(xiàn)MessageHandler。MessageHandler定義了一個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);
}