summaryrefslogtreecommitdiff
path: root/src/mongo/util/concurrency/thread_pool.cpp
diff options
context:
space:
mode:
authorAdam Midvidy <amidvidy@gmail.com>2015-06-17 10:27:13 -0400
committerAdam Midvidy <amidvidy@gmail.com>2015-06-17 13:32:39 -0400
commit449e0f2b47e32060433cb6f68d967ea53c8573d1 (patch)
tree6e857f03a636b34ad8710e0b3e35a9115523483b /src/mongo/util/concurrency/thread_pool.cpp
parentcbc69e7dcb875b35e161875317bca701b48c770c (diff)
downloadmongo-449e0f2b47e32060433cb6f68d967ea53c8573d1.tar.gz
SERVER-18723 boost -> stdx for mutex, unique_lock, and lock_guard
Diffstat (limited to 'src/mongo/util/concurrency/thread_pool.cpp')
-rw-r--r--src/mongo/util/concurrency/thread_pool.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/util/concurrency/thread_pool.cpp b/src/mongo/util/concurrency/thread_pool.cpp
index 971e45429bf..8b2d3c0b1d5 100644
--- a/src/mongo/util/concurrency/thread_pool.cpp
+++ b/src/mongo/util/concurrency/thread_pool.cpp
@@ -110,7 +110,7 @@ namespace mongo {
}
void ThreadPool::startThreads() {
- boost::lock_guard<boost::mutex> lock(_mutex);
+ stdx::lock_guard<stdx::mutex> lock(_mutex);
for (int i = 0; i < _nThreads; ++i) {
const std::string threadName(_threadNamePrefix.empty() ?
_threadNamePrefix :
@@ -138,14 +138,14 @@ namespace mongo {
}
void ThreadPool::join() {
- boost::unique_lock<boost::mutex> lock(_mutex);
+ stdx::unique_lock<stdx::mutex> lock(_mutex);
while(_tasksRemaining) {
_condition.wait(lock);
}
}
void ThreadPool::schedule(Task task) {
- boost::lock_guard<boost::mutex> lock(_mutex);
+ stdx::lock_guard<stdx::mutex> lock(_mutex);
_tasksRemaining++;
@@ -160,7 +160,7 @@ namespace mongo {
// should only be called by a worker from the worker thread
void ThreadPool::task_done(Worker* worker) {
- boost::lock_guard<boost::mutex> lock(_mutex);
+ stdx::lock_guard<stdx::mutex> lock(_mutex);
if (!_tasks.empty()) {
worker->set_task(_tasks.front());