tastytea/remwharead
1
0
Fork 0
Code Issues 1 Pull Requests Releases 37 Activity

Set the maximum number of threads to use dynamically.
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source 
The formula is reported_number_of_threads / 3 + 1. Each thread works on at least
50 entries.
This commit is contained in:
tastytea 2019-08-08 19:06:57 +02:00
parent cc4bc18062
commit 0df8e69c88
Signed by: tastytea
GPG Key ID: CFC39497F1B26E07
1 changed files with 13 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/cli/main.cpp
View File

@ -126,9 +126,19 @@ int App::main(const std::vector<std::string> &args)
{
const size_t len = entries.size();
constexpr size_t min_len = 100;
constexpr size_t n_threads = 2;
// If there are over `min_len` entries, use `n_threads` threads.
const size_t cut_at = ((len > min_len) ? (len / n_threads) : len);
constexpr size_t min_per_thread = 50;
const size_t n_threads = thread::hardware_concurrency() / 3 + 1;
size_t cut_at = len;
if (len > min_len)
{ // If there are over `min_len` entries, use `n_threads` threads.
cut_at = len / n_threads;
// But don't use less than `min_per_thread` entries per thread.
if (cut_at < min_per_thread)
{
cut_at = min_per_thread;
}
}
list<list<Database::entry>> segments;