@ -234,6 +234,8 @@ _calculate_thread_counts(int *read_thread_count_,
nproc = std::thread::hardware_concurrency();
*read_thread_count_ = 2;
*process_thread_count_ = std::max(2,(nproc - 2));
if(*process_thread_count_ > 8)
*process_thread_count_ = 8;
}
else if((*read_thread_count_ == 0) && (*process_thread_count_ != -1))
{