关于“C++ Concurrency in Action”代码的问题

Question

我正在阅读 C++ Concurrency In Action，第 32 页（第 2 章）中有这段代码。

template <typename Iterator, typename T>
struct accumulate_block
{
    void operator()(Iterator first, Iterator last, T &result)
    {
        result = std::accumulate(first, last, result);
    }
};
template <typename Iterator, typename T>
T parallel_accumulate(Iterator first, Iterator last, T init)
{
    unsigned long const length = std::distance(first, last);
    if (!length)
        return init;
    unsigned long const min_per_thread = 25;
    unsigned long const max_threads = (length + min_per_thread - 1) / min_per_thread;
    unsigned long const hardware_threads = std::thread::hardware_concurrency();
    unsigned long const num_threads = std::min(hardware_threads != 0 ? hardware_threads : 2, max_threads);
    unsigned long const block_size = length / num_threads;
    std::vector<T> results(num_threads);
    std::vector<std::thread> threads(num_threads - 1);
    Iterator block_start = first;
    for (unsigned long i = 0; i < (num_threads - 1); ++i)
    {
        Iterator block_end = block_start;
        std::advance(block_end, block_size);
        threads[i] = std::thread(accumulate_block<Iterator, T>(),
                                 block_end, std::ref(results[i]));
        block_start = block_end;
    }
 accumulate_block<Iterator,T(block_start,last,results[num_threads-1]); 
 
 for(auto& entry: threads)
     entry.join(); 
 return std::accumulate(results.begin(),results.end(),init);
}

我不明白一些事情。

1. 为什么作者选择25作为min_per_thread？这只是一个任意数字还是背后有某种想法？
2. 我不明白这段代码中的公式：

unsigned long const max_threads=
 (length+min_per_thread-1)/min_per_thread; 

为什么我们使用这个公式来查找“最大线程”以及我们需要它做什么？

我尝试围绕这段代码搜索其他类似的问题，但一无所获。

Answer 1

为什么作者选择25作为min_per_thread？这只是一个任意数字还是背后有某种想法？

该数字25是任意数字。您可以根据需要使用任何号码。

我不明白这段代码中的公式：

unsigned long const max_threads=
 (length+min_per_thread-1)/min_per_thread; 

当您除以一个数字时，例如13( length) 除以4( min_per_thread)，您将3通过整数运算得到结果。余数等于 1，因此您仅为、和3三个范围提供了线程，但该元素没有线程。您需要为其余部分提供一个线程。[0, 3][4,7][8, 11]12

你可以写：

13 + ( 4 - 1 )等于16，16除以4就会得到4。现在，其余范围中包含的所有范围都将拥有自己的线程。

例如，如果length等于，12那么添加的值min_per_thread - 1将不会影响所需的线程数（在本例中等于）3。

一般来说，余数可以是 范围内的任意值[0, min_per_thread - 1]。

特别是， iflength小于min_per_threadthen 使用不带操作数的表达式，min_per_thread - 1您将得到 max_threads等于0，尽管在任何情况下都需要一个线程。