初识chromium thread的实现

  接触chromium已有一段时间,写点东西学习一下吧。

  首先说一下用法,如何利用chromium封装好的thread类来开一个线程。在base里有一个封装该类的头文件thread.h,include它之后可以这样写一段代码(仅范例而已,具体用的时候要放在类里边儿的) 

 //a sample to use base::thread of chromium
//by zhouyoulie
//2014.03 int Fun( int para1,int para2 ); //creat a thread called thread_test
scoped_ptr<base::Thread> ThreadTest;
ThreadTest.reset(new base::Thread("thread_test")); //then start it
if (!ThreadTest->IsRunning())
ThreadTest->Start(); //use this thread to do some work which is defined in Fun
int para1,para2;
ThreadTest->message_loop()->PostTask
(FROM_HERE,NewRunnableMethod(this,&Fun, para1,para2)); ..................... //after finishing all the work,close this thread
ThreadTest->Stop();

线程用法简介

  其实用法还是比较简单的,就是几个简单的API,大牛们封装了这么好的类,带着学习的心态,来一看究竟吧,不对的地方还求指正啊,哈哈

  该类的构造函数没有做太多事情,就是初始化了一些诸如线程名称、线程id、消息循环变量等东西,代码如图1所示

初识chromium thread的实现

图1

  来看看start做了些什么事情  

初识chromium thread的实现

  图2

  首先用Options()初始化了一些选择信息,在StartWithOptions里主要调用了PlatformThread::Create来创建该线程,在creat方法里会去调一些跟平台相关的API来创建线程,直接上代码

初识chromium thread的实现

图3  

  可以很清楚的看到在平台相关的类里都是跟windows相关的代码,这句话好像是句废话,想表达的意思就是google的代码写的还是很美的,可移植性之强可见一斑,学习了。调用windows的API CreatThread后就注册了回调函数ThreadFunc,该函数体如下

初识chromium thread的实现

  这个函数其实就是利用delegate的方法再调回到类Thread的ThreadMain的方法做跟平台无关的事情,哎呀,我还得说一句,人家代码写的确实好,到时候如果我想换一个平台直接把类PlatFormThread替换掉就可以了。再来看看ThreadMain做了什么事情吧

 void Thread::ThreadMain() {
// The message loop for this thread.
MessageLoop message_loop(startup_data_->options.message_loop_type); // Complete the initialization of our Thread object.
thread_id_ = PlatformThread::CurrentId();
PlatformThread::SetName(name_.c_str());
// ANNOTATE_THREAD_NAME(name_.c_str()); // Tell the name to race detector.
message_loop.set_thread_name(name_);
message_loop_ = &message_loop; // Let the thread do extra initialization.
// Let's do this before signaling we are started.
Init(); startup_data_->event.Signal();
// startup_data_ can't be touched anymore since the starting thread is now
// unlocked. Run(message_loop_); // Let the thread do extra cleanup.
CleanUp(); // Assert that MessageLoop::Quit was called by ThreadQuitTask.
DCHECK(GetThreadWasQuitProperly()); // We can't receive messages anymore.
message_loop_ = NULL;
//thread_id_ = 0;
}

Thread::ThreadMain()

  代码有点长就不截图了。先让我简单介绍一下message loop的概念(由于这个涉及到线程安全的问题,我打算下一次专门写点东西学习一下message loop),google采用的方式类似于微软的消息模式,你可以把message_loop_想象成一个队列,之前在介绍用这个线程封装类时,是通过函数message_loop()来post一些task到这个队列的,线程会不断到队列里去取task并执行,直到遇到一个exit task后退出,我想熟悉windows 消息模式的同学一定不会陌生。代码中的Run(message_loop_)就是开启了task 队列功能,不断去取task来完成任务。

     

  

上一篇:TP支持菜单动态生成RBAC权限系统数据库结构设计方案


下一篇:nginx配合modsecurity实现WAF功能