WebRTC的线程模型
WebRTC中的线程类:
Thread类:
(1)Thread类中的数据:
class Thread
{
// 消息队列:
MessageList messages_; // 消息队列,所有需要线程处理的消息,都要先入队
PriorityQueue delayed_messages_; // 处于这个队列中的消息都是要延后处理的消息
CriticalSection crit_; //临界区,配合消息队列使用,插队、出队前都要先获取临界区
// 事件:
SocketServer *const_ss_; // 事件处理类,可能与名字中的socket无关
// 线程:
pthread_t thread_ = nullptr; // 线程
};
(2)Thread类中的重要方法:
class Thread
{
// 1. 对队列的操作:
Get();
Peek();
// 2. 用于线程切换:
Post();
PostTask();
Send();
Invoke();
// 3. 线程的控制:
start();
run();
stop();
};
关于Thread的几个要点:
- WebRTC中的Thread是一个对象,并不是线程,但是在对象中持有了一个线程
- WebRTC中的线程是有队列的
- WebRTC中的线程是以事件驱动的,也就是当收到事件通知之后,才去消息队列中获取数据,然后进行具体操作(事件驱动的性能要比轮询高效)
线程的创建:
- 不同的平台有不同的API
- Linux和Mac都用的是POSIX API,即pthread_create()
WebRTC中的线程管理:
ThreadManager类:
(1)ThreadManager类中的重要数据成员:
class ThreadManager
{
static ThreadManager *Instance_; // 单例模式 —> 【Manager一般都可以写成一个单例模式,代码借鉴】
vector<Thread*> message_queues_; // 存放所有Thread线程对象
CritalSection crit_; // 临界区,对message_queues的操作之前要加锁
pthread_key_t key_; // TLS
};