如何等待多个线程完成并重用它们？

Question

我有一个 C++ 程序，它尝试并行处理数组的每一行，并且在一行完全完成后，它会移动到下一行。我当前的程序为每一行数组创建一个线程，并在使用后加入它们。但似乎该程序在创建/关闭线程上浪费了很多时间。

有没有办法只创建一次这些线程，并且对于每一行它们等待最慢的线程完成，然后执行下一行的函数？

这是我的示例代码：

#include <iostream>
#include <thread>
using namespace std;
#define THREAD 5
int arr[2][10000];
void update_arr(int i, int j_s, int j_to){
    for (int j = j_s; j <= j_to; j++)
        arr[i%2][j]= arr[(i-1)%2][j]+2*arr[(i-1)%2][j-1];
}

int main(){
    for (int i = 0; i < 10000; i++) arr[0][i] = 1;
    for (int i = 1; i <= 10000; i++){
        thread t[THREAD];
        for (int ii = 0; ii < THREAD; ii++)
            t[ii] = thread(update_arr, i, ii * 10000 / THREAD, (ii+1) * 10000 / THREAD - 1);

        for (int ii = 0; ii < THREAD; ii++)
            t[ii].join();   
    }
    cout<<arr[1][9999]<<endl;
}

Answer 1

threadpool 旨在避免这个问题，即创建和销毁线程的成本相对较高。请注意，std::async 类可以使用线程池实现（但不能保证），因此您应该首先考虑使用它。