2. 程式人生 > >【Boost】boost庫asio詳解2——strand與io_service區別

【Boost】boost庫asio詳解2——strand與io_service區別

阿新 • • 發佈：2019-02-16
[cpp] view plain copy  print?
  1. namespace
  2. {  
  3.     // strand提供序列執行, 能夠保證執行緒安全, 同時被post或dispatch的方法, 不會被併發的執行. 
  4.     // io_service不能保證執行緒安全
  5.     boost::asio::io_service m_service;  
  6.     boost::asio::strand m_strand(m_service);  
  7.     boost::mutex m_mutex;  
  8.     void print(int id)  
  9.     {  
  10.         // boost::mutex::scoped_lock lock(m_mutex);
  11.         staticint count = 0;  
  12.         PRINT_DEBUG("id: " << boost::lexical_cast<std::string>(id));  
  13.         PRINT_DEBUG("count: " << boost::lexical_cast<std::string>(++count));  
  14.     }  
  15.     void ioRun1()  
  16.     {  
  17.         while(true)  
  18.         {  
  19.             m_service.run();  
  20.         }  
  21.     }  
  22.     void ioRun2()  
  23.     {  
  24.         while(true)  
  25.         {  
  26.             m_service.run();  
  27.         }  
  28.     }  
  29.     void strand_print1()  
  30.     {  
  31.         // PRINT_DEBUG("Enter print1");
  32.         m_strand.dispatch(boost::bind(print, 1));  
  33.         // PRINT_DEBUG("Exit print1");
  34.     }  
  35.     void strand_print2()  
  36.     {  
  37.         // PRINT_DEBUG("Enter print2");
  38.         m_strand.post(boost::bind(print, 2));  
  39.         // PRINT_DEBUG("Exit print2");
  40.     }  
  41.     void strand_print3()  
  42.     {  
  43.         // PRINT_DEBUG("Enter print3");              
  44.         m_strand.post(boost::bind(print, 3));  
  45.         // PRINT_DEBUG("Exit print3");
  46.     }  
  47.     void strand_print4()  
  48.     {  
  49.         // PRINT_DEBUG("Enter print4");
  50.         m_strand.post(boost::bind(print, 4));  
  51.         // PRINT_DEBUG("Exit print4");
  52.     }  
  53.     // 將上面的m_strand換成m_service後，
  54.     void service_print1()  
  55.     {  
  56.         // PRINT_DEBUG("Enter print1");
  57.         m_service.dispatch(boost::bind(print, 1));  
  58.         // PRINT_DEBUG("Exit print1");
  59.     }  
  60.     void service_print2()  
  61.     {  
  62.         // PRINT_DEBUG("Enter print2");
  63.         m_service.post(boost::bind(print, 2));  
  64.         // PRINT_DEBUG("Exit print2");
  65.     }  
  66.     void service_print3()  
  67.     {  
  68.         // PRINT_DEBUG("Enter print3");              
  69.         m_service.post(boost::bind(print, 3));  
  70.         // PRINT_DEBUG("Exit print3");
  71.     }  
  72.     void service_print4()  
  73.     {  
  74.         // PRINT_DEBUG("Enter print4");
  75.         m_service.post(boost::bind(print, 4));  
  76.         // PRINT_DEBUG("Exit print4");
  77.     }  
  78. }  
  79. void test_strand()  
  80. {  
  81.     boost::thread ios1(ioRun1);  
  82.     boost::thread ios2(ioRun2);  
  83.     boost::thread t1(strand_print1);  
  84.     boost::thread t2(strand_print2);  
  85.     boost::thread t3(strand_print3);  
  86.     boost::thread t4(strand_print4);  
  87.     t1.join();  
  88.     t2.join();  
  89.     t3.join();  
  90.     t4.join();  
  91.     m_server.run();  
  92. }  
  93. void test_service()  
  94. {  
  95.     boost::thread ios1(ioRun1);  
  96.     boost::thread ios2(ioRun2);  
  97.     boost::thread t1(service_print1);  
  98.     boost::thread t2(service_print2);  
  99.     boost::thread t3(service_print3);  
  100.     boost::thread t4(service_print4);  
  101.     t1.join();  
  102.     t2.join();  
  103.     t3.join();  
  104.     t4.join();  
  105.     m_service.run();  
  106. }  
test_strand的執行結果:
[cpp] view plain copy  print?
  1. 2013-01-05 17:25:34 626 [8228] DEBUG - id: 4  
  2. 2013-01-05 17:25:34 631 [8228] DEBUG - count: 1  
  3. 2013-01-05 17:25:34 634 [5692] DEBUG - id: 1  
  4. 2013-01-05 17:25:34 637 [5692] DEBUG - count: 2  
  5. 2013-01-05 17:25:34 640 [5692] DEBUG - id: 2  
  6. 2013-01-05 17:25:34 642 [5692] DEBUG - count: 3  
  7. 2013-01-05 17:25:34 646 [5692] DEBUG - id: 3  
  8. 2013-01-05 17:25:34 649 [5692] DEBUG - count: 4  
test_ioserivice的執行結果:
[cpp] view plain copy  print?
  1. 2013-01-05 17:26:28 071 [3236] DEBUG - id: 1  
  2. 2013-01-05 17:26:28 071 [5768] DEBUG - id: 2  
  3. 2013-01-05 17:26:28 071 [5108] DEBUG - id: 3  
  4. 2013-01-05 17:26:28 076 [3236] DEBUG - count: 1  
  5. 2013-01-05 17:26:28 079 [5768] DEBUG - count: 2  
  6. 2013-01-05 17:26:28 083 [5108] DEBUG - count: 3  
  7. 2013-01-05 17:26:28 087 [3236] DEBUG - id: 4  
  8. 2013-01-05 17:26:28 099 [3236] DEBUG - count: 4  
從結果可以看到, 在test_strand中print中兩個列印函式成對執行, 在test_ioservice兩個列印函式就沒有執行緒安全可言了.
如果要保證test_ioservice同步, 就要加上mutex, 在程式碼中被註釋的那句. 

注意從日誌的執行緒號中可知: 真正執行print()是主執行緒, ios1, ios2, 而t1, t2, t3, t4執行緒只是往ioservice的佇列中加入任務.

相關推薦

【Boost】boost庫asio詳解2——strand與io_service區別

[cpp] view plain copy  print? namespace {       // strand提供序列執行, 能夠保證執行緒安全, 同時被post或dispatch的方法, 不會被併發的執行.      // io_service不能保證

【Boost】boost庫asio詳解4——deadline_timer使用說明

deadline_timer和socket一樣，都用io_service作為建構函式的引數。也即，在其上進行非同步操作，都將導致和io_service所包含的iocp相關聯。這同樣意味著在析構 io_service之前

boost庫asio詳解4——deadline_timer使用說明

deadline_timer和socket一樣，都用io_service作為建構函式的引數。也即，在其上進行非同步操作，都將導致和io_service所包含的iocp相關聯。這同樣意味著在析構 io_service之前，必須析構關聯在這個io_service上的deadli

【轉載】瀏覽器緩存詳解：expires cache-control last-modified

導致 lang -c csdn 判斷 屬性 lan -m load 最近在對CDN進行優化，對瀏覽器緩存深入研究了一下，記錄一下，方便後來者 畫了一個草圖： 每個狀態的詳細說明如下： 1、Last-Modified 在瀏覽器第一次請求某一個URL時，服務器端的返回

【轉】linux awk命令詳解

column 環境變量 最後一行 工作流程 初始 文本文件 for循環 其中 cti 簡介 awk是一個強大的文本分析工具，相對於grep的查找，sed的編輯，awk在其對數據分析並生成報告時，顯得尤為強大。簡單來說awk就是把文件逐行的讀入，以空格為默認分隔符將每行切

【HTTP】---HTTP狀態碼詳解

無法 用戶輸入 格式 type 發送 pan http 節點 wiki https://en.wikipedia.org/wiki/List_of_HTTP_status_codes 1、百科名片 HTTP狀態碼（HTTP Status Code）是用以表示網頁服

【HTML】Http分段下載詳解

多線程 ces 數值 alt locks www. 支持 read rand 一.為什麽需要Http分段下載 在實際的業務開發中，大文件使用Http普通下載非常容易OOM(內存溢出)或是鏈接超時的錯誤，這種情況下應該就應該考慮使用Http的分段下載了。下面筆者為你

【轉】Code First 屬性詳解

map 時間 range get con 如果 per rem att 下面解釋每個配置的作用 Table ：用於指定生成表的表名、架構信息。 Column ：用於指定生成數據表的列信息，如列名、數據類型、順序等。 Key ：用於指定任何名稱的屬性作為主鍵列並且默認將此列作

【轉】Lambda表達式詳解

執行 pan mpi 新增 turn sum 下層 裏的 泛型類 前言 1、天真熱，程序員活著不易，星期天，也要頂著火辣辣的太陽，總結這些東西。 2、誇誇lambda吧：簡化了匿名委托的使用，讓你讓代碼更加簡潔，優雅。據說它是微軟自c#1

【MySQL】lower_case_table_names參數詳解

安裝 系統 str pre 大寫 mysq db_name mysql 查看 簡介： lower_case_table_names 是mysql設置大小寫是否敏感的一個參數。 1.參數說明： lower_case_table_names=0 表名存儲為給定的大小和比較是

【TestNG】TestNG依賴測試詳解

一、TestNG安裝與基本使用 參考部落格https://blog.csdn.net/df0128/article/details/83243822； 二、TestNG依賴的使用 TestNG支援用例或者組之間的依賴。 雖然我們有多種@Before可以使用，看起來和依賴效果一樣，

【TestNG】TestNG使用教程詳解

一、TestNG介紹 TestNG是Java中的一個測試框架， 類似於JUnit 和NUnit, 功能都差不多， 只是功能更加強大，使用也更方便。 詳細使用說明請參考官方連結：https://testng.org/doc/index.html 二、TestNG安裝（基於eclipse

【JAVA】的內部類詳解

轉載部落格： https://www.cnblogs.com/dolphin0520/p/3811445.html 作者：海 子 　　說起內部類這個詞，想必很多人都不陌生，但是又會覺得不熟悉。原因是平時編寫程式碼時可能用到的場景不多

【linux】Valgrind工具集詳解（十五）：Callgrind（效能分析圖）

一、概述 1、Callgrind Callgrind用於記錄程式中函式之間的呼叫歷史資訊，對程式效能分析。預設情況下，收集的資料包括執行的指令數，它們與原始碼行的關係，函式之間的呼叫者、被呼叫者關係以及此類呼叫的數量。可選項是，對快取記憶體模擬和分支預測（類似於Cachegrin

【linux】Valgrind工具集詳解（十四）：Cachegrind（快取和分支預測分析器）

一、概述 Cachegrind，它模擬CPU中的一級快取I1，Dl和二級快取，能夠精確地指出程式中cache的丟失和命中。如果需要，它還能夠為我們提供cache丟失次數，記憶體引用次數，以及每行程式碼，每個函式，每個模組，整個程式產生的指令數。這對優化程式有很大的幫助。 Cach

【linux】Valgrind工具集詳解（十三）：DRD（執行緒錯誤檢測器）

一、概述 多執行緒程式設計需要注意的問題： 資料競爭；鎖競爭；POSIX執行緒API使用不當；死鎖； 二、使用 1、例子main.c原始碼 #include <stdio.h> #include <pthread.h> #include <s

【linux】Valgrind工具集詳解（十三）：Helgrind（執行緒錯誤檢測器）

一、概述 Helgrind用於檢測C、C ++和Fortran程式中使用符合POSIX標準的執行緒函式造成的同步錯誤。 POSIX中關於執行緒的主要抽象描述有：共享公共地址空間的一組執行緒、執行緒建立、執行緒連線、執行緒退出、互斥（鎖）、條件變數（執行緒間事件通知）、讀寫器鎖、自

【linux】Valgrind工具集詳解（十二）：DHAT：動態堆分析器

一、概述 DHAT動態堆分析器。Massif（堆分析器）是在程式結束後輸出分析結果，而DHAT是實時輸出結果，所以叫做動態堆分析器。Massif只記錄堆記憶體的申請和釋放，DHAT還會分析堆空間的使用率、使用週期等資訊。 DHAT的功能：它首先記錄在堆上分配的塊，通過分析每次記憶體訪

【linux】Valgrind工具集詳解（十一）：Massif（堆分析器）

一、概述 Massif是一個堆分析器。它統計程式使用的堆記憶體大小（由malloc等函式分配的記憶體）。預設情況下不統計程式所使用的所有記憶體，如果想統計所有記憶體，需要使用選項–pages-as-heap=yes。 堆分析可以幫助減少程式使用的記憶體。如果分配的記憶體還沒有釋放

【linux】Valgrind工具集詳解（十）：SGCheck（檢查棧和全域性陣列溢位）

一、概述 SGCheck是一種用於檢查棧中和全域性陣列溢位的工具。它的工作原理是使用一種啟發式方法，該方法源於對可能的堆疊形式和全域性陣列訪問的觀察。 棧中的資料：例如函式內宣告陣列int a[10]，而不是malloc分配的，malloc分配的記憶體是在堆中。 SGCheck和Me