WebRTC Thread Model

Abstract	WebRTC 线程模型
Authors	Walter Fan
Status	v1.0
Updated	2026-08-17

概述 

WebRTC 的线程模型是其架构的核心，理解它是阅读源码的前提。 WebRTC 使用三个主要线程，每个线程有明确的职责边界和严格的调用规则。

        flowchart TB
  App[应用层 JavaScript / Native API] -->|API 调用与回调| Sig["Signaling Thread 信令线程<br/>PeerConnection API 入口<br/>SDP 创建与解析<br/>Observer 回调"]
  Sig -->|同步调用| W["Worker Thread 工作线程<br/>编解码 / 媒体处理<br/>拥塞控制 / 音频设备"]
  Sig -->|同步调用| N["Network Thread 网络线程<br/>ICE/DTLS/SRTP<br/>Socket 读写 / 数据收发 / TURN"]
  W --> N

调用规则 

WebRTC 对线程间调用有严格约束，违反会触发 RTC_DCHECK 断言：

调用方	可调用	说明
Signaling Thread	Worker Thread	同步调用（阻塞等待结果）
Worker Thread	Network Thread	同步调用
Network Thread	（无）	不能被其他线程阻塞，也不能同步调用其他线程
任意线程	任意线程	可以异步 Post 消息（非阻塞）

关键原则：Network Thread 永远不能被阻塞，因为它直接处理网络 I/O，阻塞会导致丢包和连接超时。

核心类 

Thread 

rtc::Thread 是 WebRTC 的线程基类，内部维护一个消息队列（TaskQueue）。

class Thread : public TaskQueueBase {
public:
    // 在目标线程上同步执行（阻塞当前线程）
    template <typename Functor>
    auto Invoke(const Location& posted_from, Functor&& functor);

    // 在目标线程上异步执行（不阻塞）
    void PostTask(absl::AnyInvocable<void() &&> task);

    // 延迟执行
    void PostDelayedTask(absl::AnyInvocable<void() &&> task,
                         TimeDelta delay);

    // 启动线程消息循环
    void Run();

    // 停止线程
    void Stop();

    // 获取当前线程
    static Thread* Current();
};

Invoke()：跨线程同步调用，内部通过消息队列传递任务并等待完成
PostTask()：异步投递，不等待结果
RTC_DCHECK_RUN_ON(thread)：编译期+运行期检查当前是否在指定线程上

TaskQueue 

TaskQueueBase 是更轻量的任务队列抽象，不一定绑定 OS 线程：

std::unique_ptr<TaskQueueFactory> CreateDefaultTaskQueueFactory() {
    return CreateTaskQueueStdlibFactory();
}

WebRTC 内部很多模块使用 TaskQueue 而非直接使用 Thread，以便在不同平台选择最优的实现（POSIX、Win32、stdlib）。

Dispatcher (事件分派)

Network Thread 内部使用事件驱动模型处理 Socket I/O：

class Dispatcher {
public:
    virtual uint32_t GetRequestedEvents() = 0;
    virtual void OnEvent(uint32_t ff, int err) = 0;
#if defined(WEBRTC_WIN)
    virtual WSAEVENT GetWSAEvent() = 0;
    virtual SOCKET GetSocket() = 0;
#elif defined(WEBRTC_POSIX)
    virtual int GetDescriptor() = 0;
    virtual bool IsDescriptorClosed() = 0;
#endif
};

Windows：使用 WSAEventSelect + WSAWaitForMultipleEvents
POSIX：使用 poll() 或 epoll()

线程安全注解 

WebRTC 大量使用 Clang 线程安全注解来在编译期检测错误：

class VideoSendStream {
    Mutex mutex_;
    // 编译器检查：访问 config_ 前必须持有 mutex_
    Config config_ RTC_GUARDED_BY(mutex_);

    // 编译器检查：此方法只能在 worker_thread_ 上调用
    void SetSource(...) RTC_RUN_ON(worker_thread_);
};

常用注解：

注解	含义
`RTC_GUARDED_BY(mu)`	访问此变量前必须持有锁 `mu`
`RTC_RUN_ON(thread)`	此方法只能在指定线程上调用
`RTC_DCHECK_RUN_ON(thread)`	运行时断言当前在指定线程上
`RTC_EXCLUSIVE_LOCKS_REQUIRED(mu)`	调用此方法前必须持有锁

实际场景中的线程交互 

以发送视频为例：

        flowchart TD
  Cap[摄像头采集 Capture Thread] -->|OnFrame 回调| Sig[Signaling Thread]
  Sig -->|VideoTrackSource 分发| W[Worker Thread]
  W --> Enc["VideoStreamEncoder::OnFrame 编码"]
  Enc --> Pac["PacedSender::EnqueuePackets"]
  Pac --> Net[Network Thread]
  Net --> RTP[RTP 打包]
  RTP --> SRTP[SRTP 加密]
  SRTP --> Sock[Socket 发送]
  Sock --> NW[网络]

FAQ 

如何创建 PeerConnectionFactory 并指定线程？

auto network_thread = rtc::Thread::CreateWithSocketServer();
network_thread->Start();

auto worker_thread = rtc::Thread::Create();
worker_thread->Start();

auto signaling_thread = rtc::Thread::Create();
signaling_thread->Start();

auto factory = webrtc::CreatePeerConnectionFactory(
    network_thread.get(),
    worker_thread.get(),
    signaling_thread.get(),
    /*default_adm=*/nullptr,
    webrtc::CreateBuiltinAudioEncoderFactory(),
    webrtc::CreateBuiltinAudioDecoderFactory(),
    std::make_unique<webrtc::VideoEncoderFactoryTemplate<
        webrtc::LibvpxVp8EncoderTemplateAdapter>>(),
    std::make_unique<webrtc::VideoDecoderFactoryTemplate<
        webrtc::LibvpxVp8DecoderTemplateAdapter>>(),
    /*audio_mixer=*/nullptr,
    /*audio_processing=*/nullptr);