From 1b1df06741db2368ed05d7589b5588edfeb68fae Mon Sep 17 00:00:00 2001
From: Alon Zakai <alonzakai@gmail.com>
Date: Fri, 15 Apr 2016 20:48:15 -0700
Subject: allow limiting # of cores in thread pool, useful for debugging

---
 src/support/threads.cpp | 3 +++
 1 file changed, 3 insertions(+)

(limited to 'src/support/threads.cpp')

diff --git a/src/support/threads.cpp b/src/support/threads.cpp
index 6edff21cb..2f558d051 100644
--- a/src/support/threads.cpp
+++ b/src/support/threads.cpp
@@ -117,6 +117,9 @@ void ThreadPool::initialize(size_t num) {
 ThreadPool* ThreadPool::get() {
   if (!pool) {
     size_t num = std::max(1U, std::thread::hardware_concurrency());
+    if (getenv("BINARYEN_CORES")) {
+      num = std::stoi(getenv("BINARYEN_CORES"));
+    }
     pool = std::unique_ptr<ThreadPool>(new ThreadPool());
     pool->initialize(num);
   }
-- 
cgit v1.2.3


From 60f1c1516df1218b37f1cd2caba847c48ba93f67 Mon Sep 17 00:00:00 2001
From: Alon Zakai <alonzakai@gmail.com>
Date: Fri, 15 Apr 2016 20:48:57 -0700
Subject: fix ThreadPool::size, we don't have any thread objects created if
 there is just one core, since then we run it all on the main thread anyhow

---
 src/support/threads.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'src/support/threads.cpp')

diff --git a/src/support/threads.cpp b/src/support/threads.cpp
index 2f558d051..e67e7dedb 100644
--- a/src/support/threads.cpp
+++ b/src/support/threads.cpp
@@ -155,7 +155,7 @@ void ThreadPool::work(std::vector<std::function<ThreadWorkState ()>>& doWorkers)
 }
 
 size_t ThreadPool::size() {
-  return threads.size();
+  return std::max(size_t(1), threads.size());
 }
 
 bool ThreadPool::isRunning() {
-- 
cgit v1.2.3