Change default value of num_threads (#169)

sail-sg · Jul 15, 2022 · ea86c2b · ea86c2b
1 parent b1b9434
commit ea86c2b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/envpool/core/async_envpool.h b/envpool/core/async_envpool.h
@@ -87,7 +87,7 @@ class AsyncEnvPool : public EnvPool<typename Env::Spec> {
       f.get();
     }
     if (num_threads_ == 0) {
-      num_threads_ = batch_;
+      num_threads_ = std::min(batch_, processor_count);
     }
     for (std::size_t i = 0; i < num_threads_; ++i) {
       workers_.emplace_back([this] {