初识chromium thread的实现

 1 //a sample to use base::thread of chromium
 2 //by zhouyoulie
 3 //2014.03
 4 
 5 int Fun( int para1,int para2 );
 6 
 7 //creat a thread called thread_test
 8 scoped_ptr<base::Thread> ThreadTest;
 9 ThreadTest.reset(new base::Thread("thread_test"));
10 
11 //then start it
12 if (!ThreadTest->IsRunning())
13     ThreadTest->Start();
14 
15 //use this thread to do some work which is defined in Fun
16 int para1,para2;
17 ThreadTest->message_loop()->PostTask
18 (FROM_HERE,NewRunnableMethod(this,&Fun, para1,para2));
19 
20 .....................
21 
22 //after finishing all the work,close this thread
23 ThreadTest->Stop(1000);

 1 void Thread::ThreadMain() {
 2         // The message loop for this thread.
 3         MessageLoop message_loop(startup_data_->options.message_loop_type);
 4 
 5         // Complete the initialization of our Thread object.
 6         thread_id_ = PlatformThread::CurrentId();
 7         PlatformThread::SetName(name_.c_str());
 8 //        ANNOTATE_THREAD_NAME(name_.c_str());  // Tell the name to race detector.
 9         message_loop.set_thread_name(name_);
10         message_loop_ = &message_loop;
11 
12         // Let the thread do extra initialization.
13         // Let‘s do this before signaling we are started.
14         Init();
15 
16         startup_data_->event.Signal();
17         // startup_data_ can‘t be touched anymore since the starting thread is now
18         // unlocked.
19 
20         Run(message_loop_);
21 
22         // Let the thread do extra cleanup.
23         CleanUp();
24 
25         // Assert that MessageLoop::Quit was called by ThreadQuitTask.
26         DCHECK(GetThreadWasQuitProperly());
27 
28         // We can‘t receive messages anymore.
29         message_loop_ = NULL;
30         //thread_id_ = 0;
31     }