aboutsummaryrefslogtreecommitdiff
path: root/src/common/threadpool.cpp
diff options
context:
space:
mode:
authorHoward Chu <hyc@symas.com>2017-09-15 00:28:48 +0100
committerHoward Chu <hyc@symas.com>2017-09-15 00:28:48 +0100
commit6d0ca7d11f18d1d842ec1ac639da4309ae41a83f (patch)
tree756c8c666df79b0f15dba3f0bac15505453966e9 /src/common/threadpool.cpp
parentUse a threadpool (diff)
downloadmonero-6d0ca7d11f18d1d842ec1ac639da4309ae41a83f.tar.xz
Tweak concurrency limits
Create capacity for 2x max, but lie about it
Diffstat (limited to 'src/common/threadpool.cpp')
-rw-r--r--src/common/threadpool.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/src/common/threadpool.cpp b/src/common/threadpool.cpp
index f7f9bbbaf..41d0c25e0 100644
--- a/src/common/threadpool.cpp
+++ b/src/common/threadpool.cpp
@@ -39,7 +39,7 @@ namespace tools
threadpool::threadpool() : running(true), active(0) {
boost::thread::attributes attrs;
attrs.set_stack_size(THREAD_STACK_SIZE);
- max = tools::get_max_concurrency();
+ max = tools::get_max_concurrency() * 2;
size_t i = max;
while(i--) {
threads.push_back(boost::thread(attrs, boost::bind(&threadpool::run, this)));
@@ -73,6 +73,10 @@ void threadpool::submit(waiter *obj, std::function<void()> f) {
}
}
+int threadpool::get_max_concurrency() {
+ return max / 2;
+}
+
void threadpool::waiter::wait() {
boost::unique_lock<boost::mutex> lock(mt);
while(num) cv.wait(lock);