@ -230,8 +230,7 @@ _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;
*process_thread_count_ = std::min(8,*process_thread_count_);
}
else if((*read_thread_count_ == 0) && (*process_thread_count_ != -1))
{