fix direction of comparison

tbb::global control restricts pool size, not the other way around
root-project · Jan 7, 2021 · 7c21c51 · 7c21c51
1 parent ca8b5ed
commit 7c21c51
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/imt/src/TThreadExecutor.cxx b/core/imt/src/TThreadExecutor.cxx
@@ -155,7 +155,7 @@ TThreadExecutor::TThreadExecutor(UInt_t nThreads)
 void TThreadExecutor::ParallelFor(unsigned int start, unsigned int end, unsigned step,
                                   const std::function<void(unsigned int i)> &f)
 {
-   if (GetPoolSize() < tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism)) {
+   if (GetPoolSize() > tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism)) {
       Warning("TThreadExecutor::ParallelFor",
               "tbb::global_control is limiting the number of parallel workers."
               " Proceeding with %ld threads this time",
@@ -177,7 +177,7 @@ void TThreadExecutor::ParallelFor(unsigned int start, unsigned int end, unsigned
 double TThreadExecutor::ParallelReduce(const std::vector<double> &objs,
                                        const std::function<double(double a, double b)> &redfunc)
 {
-   if (GetPoolSize() < tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism)) {
+   if (GetPoolSize() > tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism)) {
       Warning("TThreadExecutor::ParallelReduce",
               "tbb::global_control is limiting the number of parallel workers."
               " Proceeding with %ld threads this time",