commit e237d8b9f7e4623a5c648524fd00da90b2603422
author James Yin <ywhjames@hotmail.com> Mon Nov 11 09:53:10 2019 +0800
committer dinglei <libya_003@163.com> Mon Nov 11 09:53:10 2019 +0800
tree cb1a51980cc4aa837e027fd5ab01defc090deb2f
parent ce126b723672d1130ed3660d02d61057e5af5f5c

replace boost::thread::hardware_concurrency with std::thread::hardware_concurrency. (#171)

src/common/MQClient.cpp

diff --git a/src/common/MQClient.cpp b/src/common/MQClient.cpp
index 42d77a5..b2b9937 100644
--- a/src/common/MQClient.cpp
+++ b/src/common/MQClient.cpp
@@ -41,7 +41,7 @@
   m_instanceName = "DEFAULT";
   m_clientFactory = NULL;
   m_serviceState = CREATE_JUST;
-  m_pullThreadNum = boost::thread::hardware_concurrency();
+  m_pullThreadNum = std::thread::hardware_concurrency();
   m_tcpConnectTimeout = 3000;        // 3s
   m_tcpTransportTryLockTimeout = 3;  // 3s
   m_unitName = "";

src/consumer/DefaultMQPushConsumer.cpp

diff --git a/src/consumer/DefaultMQPushConsumer.cpp b/src/consumer/DefaultMQPushConsumer.cpp
index caa539e..7e47e15 100644
--- a/src/consumer/DefaultMQPushConsumer.cpp
+++ b/src/consumer/DefaultMQPushConsumer.cpp
@@ -205,8 +205,8 @@
   setMessageModel(CLUSTERING);
 
   m_startTime = UtilAll::currentTimeMillis();
-  m_consumeThreadCount = boost::thread::hardware_concurrency();
-  m_pullMsgThreadPoolNum = boost::thread::hardware_concurrency();
+  m_consumeThreadCount = std::thread::hardware_concurrency();
+  m_pullMsgThreadPoolNum = std::thread::hardware_concurrency();
   m_async_service_thread.reset(new boost::thread(boost::bind(&DefaultMQPushConsumer::boost_asio_work, this)));
 }