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

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 类可以使用线程池实现(但不能保证)，因此您应该首先考虑使用它。