Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7893998
  • 博文数量: 701
  • 博客积分: 2150
  • 博客等级: 上尉
  • 技术积分: 13233
  • 用 户 组: 普通用户
  • 注册时间: 2011-06-29 16:28
个人简介

天行健,君子以自强不息!

文章分类

全部博文(701)

文章存档

2019年(2)

2018年(12)

2017年(76)

2016年(120)

2015年(178)

2014年(129)

2013年(123)

2012年(61)

分类: Android平台

2016-02-19 13:10:46

1, 基本线程

webretc中主要有两个线程:

signaling_thread-->处理小工作量方法。要求此线程内的方法都必须快速返回。

worker_thread-->处理大工作量的方法。此线程内的方法可能会处理很长时间,如网络消息等。

2, 线程实现

webrtc中的线程包含了一个消息队列。当需要在此线程中运行逻辑时,仅需要向线程对象发送一个消息即可。其中消息包含消息的处理类。

thread主要方法:

virtual void Post(MessageHandler *phandler, uint32 id = 0,  MessageData *pdata = NULL, bool time_sensitive = false);

发送一个异步请求,调用会立即返回。


virtual void PostDelayed(int cmsDelay, MessageHandler *phandler, uint32 id = 0, MessageData *pdata = NULL);

发送一个异步请求,调用会立即返回,但是此请求会在cmsDelay后被处理。相当于集成了个计时器。


virtual void Send(MessageHandler *phandler, uint32 id = 0,  MessageData *pdata = NULL);
发送一个同步请求,消息处理完成后调用才会返回。


3, 线程调用实现

3.1 发送一个消息。

thread->send() 

thread->post()

3.2 调用Invoke

worker_thread_->Invoke(Bind(&MediaEngineInterface::SetOutputVolume, media_engine_, level));

以上调用表示在worker_thread_内同步调用media_engine_类的MediaEngineInterface::SetOutputVolume方法,方法有一个参数是level


3.3 用proxy宏

如下用PROXY宏定义对应类的proxy类,此proxy类的所有方法都会在woker_thread_线程内调用

BEGIN_PROXY_MAP(PeerConnection)
  PROXY_METHOD0(talk_base::scoped_refptr,
                local_streams)
  PROXY_METHOD0(talk_base::scoped_refptr,
                remote_streams)
  PROXY_METHOD2(bool, AddStream, MediaStreamInterface*,
                const MediaConstraintsInterface*)
  PROXY_METHOD1(void, RemoveStream, MediaStreamInterface*)
  PROXY_METHOD1(talk_base::scoped_refptr,
                CreateDtmfSender, AudioTrackInterface*)
  PROXY_METHOD2(bool, GetStats, StatsObserver*, MediaStreamTrackInterface*)
  PROXY_METHOD2(talk_base::scoped_refptr,
                CreateDataChannel, const std::string&, const DataChannelInit*)
  PROXY_CONSTMETHOD0(const SessionDescriptionInterface*, local_description)
  PROXY_CONSTMETHOD0(const SessionDescriptionInterface*, remote_description)
  PROXY_METHOD2(void, CreateOffer, CreateSessionDescriptionObserver*,
                const MediaConstraintsInterface*)
  PROXY_METHOD2(void, CreateAnswer, CreateSessionDescriptionObserver*,
                const MediaConstraintsInterface*)
  PROXY_METHOD2(void, SetLocalDescription, SetSessionDescriptionObserver*,
                SessionDescriptionInterface*)
  PROXY_METHOD2(void, SetRemoteDescription, SetSessionDescriptionObserver*,
                SessionDescriptionInterface*)
  PROXY_METHOD2(bool, UpdateIce, const IceServers&,
                const MediaConstraintsInterface*)
  PROXY_METHOD1(bool, AddIceCandidate, const IceCandidateInterface*)
  PROXY_METHOD0(SignalingState, signaling_state)
  PROXY_METHOD0(IceState, ice_state)
  PROXY_METHOD0(IceConnectionState, ice_connection_state)
  PROXY_METHOD0(IceGatheringState, ice_gathering_state)
  PROXY_METHOD0(void, Close)
END_PROXY()

PeerConnectionProxy(woker_thread_, peer_connection);


原文地址:http://blog.csdn.net/oupeng1991/article/details/28619835

阅读(3110) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~