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_refptr<base::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 }