neurocyte/thespian
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge commit '9ca04ddfc715e0f7d29d3f6b39269ad9bf174230'

Browse source
This commit is contained in:
CJ van den Berg 2025-02-11 18:35:15 +01:00
commit a3f0f5b089
Signed by: neurocyte
GPG key ID: 8EB1E1BB660E3FB9
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/executor_asio.cpp
View file

@ -58,12 +58,16 @@ using asio::windows::stream_handle;
namespace thespian::executor { namespace thespian::executor {
const char *MIN_THREAD_STR = getenv("MIN_THREAD"); // NOLINT
const auto MIN_THREAD =
static_cast<long>(atoi(MIN_THREAD_STR ? MIN_THREAD_STR : "4")); // NOLINT
const char *MAX_THREAD_STR = getenv("MAX_THREAD"); // NOLINT const char *MAX_THREAD_STR = getenv("MAX_THREAD"); // NOLINT
const auto MAX_THREAD = const auto MAX_THREAD =
static_cast<long>(atoi(MAX_THREAD_STR ? MAX_THREAD_STR : "64")); // NOLINT static_cast<long>(atoi(MAX_THREAD_STR ? MAX_THREAD_STR : "64")); // NOLINT
#if !defined(_WIN32) #if !defined(_WIN32)
const auto threads = min(sysconf(_SC_NPROCESSORS_ONLN), MAX_THREAD); const auto threads = max(min(sysconf(_SC_NPROCESSORS_ONLN), MAX_THREAD), MIN_THREAD);
#else #else
namespace { namespace {
static auto get_num_processors() -> long { static auto get_num_processors() -> long {
@ -72,7 +76,7 @@ static auto get_num_processors() -> long {
return si.dwNumberOfProcessors; return si.dwNumberOfProcessors;
} }
} // namespace } // namespace
const auto threads = min(get_num_processors(), MAX_THREAD); const auto threads = max(min(get_num_processors(), MAX_THREAD), MIN_THREAD);
#endif #endif
struct context_impl { struct context_impl {