Chromium 消息循环和线程池详解

 1 #include "base/logging.h"
 2 #include "base/message_loop/message_loop.h"
 3 #include "base/message_loop/message_loop_current.h"
 4 #include "base/task/post_task.h"
 5 #include "base/task/single_thread_task_executor.h"
 6 #include "base/task/thread_pool/thread_pool_impl.h"
 7 #include "base/task/thread_pool/thread_pool_instance.h"
 8 #include "base/threading/thread_task_runner_handle.h"
 9 #include "base/timer/timer.h"
10 
11 void Hello() {
12   LOG(INFO) "hello,demo!";
13 }
14 
15 int main(int argc, char** argv) {
16   // 创建消息循环
17   base::MessageLoop message_loop;
18   // 也可以使用下面的方法。它们的区别仅在于 MessageLoop 对外暴露了更多的内部接口。
19   // 在当前线程创建一个可执行 task 的环境，同样需要使用 RunLoop 启动
20   // base::SingleThreadTaskExecutor main_task_executer;
21 
22   base::RunLoop run_loop;
23 
24   // 使用 message_loop 对象直接创建任务
25   message_loop.task_runner()->PostTask(FROM_HERE, base::BindOnce(&Hello));
26   // 获取当前线程的 task runner
27   base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
28                                                 base::BindOnce(&Hello));
29 
30   // 启动消息循环，即使没有任务也会阻塞程序运行。当前进程中只有一个线程。
31   run_loop.Run();
32 
33   return 0;
34 }

 1 #include base/logging.h>
 2 #include base/message_loop/message_loop.h>
 3 #include base/task/post_task.h>
 4 #include base/task/task_scheduler/task_scheduler.h>
 5 
 6 void Hello()
 7 {
 8     LOG(INFO)"hello,demo!";
 9 }
10 
11 int main(int argc,char** argv)
12 {
13   // 初始化线程池，会创建新的线程，在新的线程中会创建消息循环 MessageLoop
14   base::TaskScheduler::CreateAndStartWithDefaultParams("Demo");
15 
16   // 通过以下方法创建任务
17   base::PostTask(FROM_HERE, base::BindOnce(&Hello));
18   // 或者通过创建新的TaskRunner来创建任务，TaskRunner可以控制任务执行的顺序以及是否在同一个线程中运行
19   scoped_refptrbase::TaskRunner> task_runner_ =
20     base::CreateTaskRunnerWithTraits({base::TaskPriority::USER_VISIBLE});
21   task_runner_->PostTask(FROM_HERE,base::BindOnce(&Hello));
22 
23   // 不能使用以下方法创建任务，会导致程序崩溃，因为当前线程没有创建消息循环
24   //base::MessageLoopCurrent::Get()->task_runner()->PostTask(FROM_HERE, base::BindOnce(&Hello));
25 
26   // 由于线程池默认不会阻塞程序运行，因此这里为了看到结果使用getchar()阻塞主线程。当前进程中共有4个线程，1个主线程，1个线程池Service线程，2个Worker线程。
27   getchar();
28 
29   return 0;
30 }