mirrors/yosys
3
0
Fork 0
mirror of https://github.com/YosysHQ/yosys synced 2025-12-18 18:28:35 +00:00
Code Activity

Add YOSYS_MAX_THREADS

Browse source
This commit is contained in:
Robert O'Callahan 2025-09-30 15:42:10 +00:00 • committed by Emil J. Tywoniak
parent 52b1245547
commit 7219ac94b3
2 changed files with 19 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

19
kernel/threading.cc
View file

@ -3,6 +3,20 @@
YOSYS_NAMESPACE_BEGIN YOSYS_NAMESPACE_BEGIN
static int init_max_threads()
{
const char *v = getenv("YOSYS_MAX_THREADS");
if (v == nullptr)
return INT32_MAX;
return atoi(v);
}
static int get_max_threads()
{
static int max_threads = init_max_threads();
return max_threads;
}
void DeferredLogs::flush() void DeferredLogs::flush()
{ {
for (auto &m : logs) for (auto &m : logs)
@ -12,10 +26,11 @@ void DeferredLogs::flush()
YOSYS_NAMESPACE_PREFIX log("%s", m.text.c_str()); YOSYS_NAMESPACE_PREFIX log("%s", m.text.c_str());
} }
int ThreadPool::pool_size(int reserved_cores, int max_threads) int ThreadPool::pool_size(int reserved_cores, int max_worker_threads)
{ {
#ifdef YOSYS_ENABLE_THREADS #ifdef YOSYS_ENABLE_THREADS
int num_threads = std::min<int>(std::thread::hardware_concurrency() - reserved_cores, max_threads); int available_threads = std::min<int>(std::thread::hardware_concurrency(), get_max_threads());
int num_threads = std::min(available_threads - reserved_cores, max_worker_threads);
return std::max(0, num_threads); return std::max(0, num_threads);
#else #else
return 0; return 0;

4
kernel/threading.h
View file

@ -127,9 +127,9 @@ class ThreadPool
public: public:
// Computes the number of worker threads to use. // Computes the number of worker threads to use.
// `reserved_cores` cores are set aside for other threads (e.g. work on the main thread). // `reserved_cores` cores are set aside for other threads (e.g. work on the main thread).
// `max_threads` --- don't return more workers than this. // `max_worker_threads` --- don't return more workers than this.
// The result may be 0. // The result may be 0.
static int pool_size(int reserved_cores, int max_threads); static int pool_size(int reserved_cores, int max_worker_threads);
// Create a pool of threads running the given closure (parameterized by thread number). // Create a pool of threads running the given closure (parameterized by thread number).
// `pool_size` must be the result of a `pool_size()` call. // `pool_size` must be the result of a `pool_size()` call.