From bf57cc5ee01ebc08cdf0795f251ddb5976df6243 Mon Sep 17 00:00:00 2001
From: James Yin <ywhjames@hotmail.com>
Date: Tue, 30 Jul 2019 06:40:58 +0800
Subject: [PATCH] replace boost::thread::hardware_concurrency with
std::thread::hardware_concurrency.
---
src/common/MQClient.cpp | 2 +-
src/consumer/DefaultMQPushConsumer.cpp | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/src/common/MQClient.cpp b/src/common/MQClient.cpp
index 42d77a526..b2b993745 100644
--- a/src/common/MQClient.cpp
+++ b/src/common/MQClient.cpp
@@ -41,7 +41,7 @@ MQClient::MQClient() {
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 = "";
diff --git a/src/consumer/DefaultMQPushConsumer.cpp b/src/consumer/DefaultMQPushConsumer.cpp
index 0f51ea135..cdec8d59f 100644
--- a/src/consumer/DefaultMQPushConsumer.cpp
+++ b/src/consumer/DefaultMQPushConsumer.cpp
@@ -205,8 +205,8 @@ DefaultMQPushConsumer::DefaultMQPushConsumer(const string& groupname)
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)));
}