c++ - 如何处理多个线程的重复启动？

Question

直到现在，在使用线程时，我总是在我的程序中立即启动它们，然后让它们等待来自主控制线程的通知。

std::vector<std::thread> threads;
for(int i = 0; i != thread_count; ++i) {
    threads.push_back(std::thread(&MyClass::myfunction, this));
}

/* some time later in the code */
for(auto& t : threads) {
    t.join();
}

现在我想从我的控制线程运行的函数按需启动线程，但我不确定如何处理线程对象及其连接。

下面会在每次调用时将一个新的线程对象推送到 vector 上，这让我觉得不太理想:

std::vector<std::thread> threads;
while(accumulating_data) {
    if(buffer_full) {
        threads.push_back(std::thread(&MyClass::myfunction, this));
    }
}

让 vector 在连续运行的线程上保持不超过最大数量似乎更可取。我也不知道如何在不阻塞控制线程的情况下加入线程。

如果我改为这样做:

// dummy code, in my real code I have a queue of idle IDs
std::vector<std::thread> threads(thread_count);
while(accumulating_data) {
    if(buffer_full) {
        threads[thread_id] = std::thread(&MyClass::myfunction, this);
        if(++thread_id == thread_count) { thread_id = 0; }
    }
}

...我很快就崩溃了，可能是因为我没有加入或正在重新分配给一个已经包含 std::thread 对象的 vector 元素。

关于如何实现按需启动线程而不是让它们等待的目标的任何提示？

更新:

通过引入 std::thread.joinable() 检查，我设法让代码在不崩溃的情况下运行。我仍然对如何更优雅地处理这个问题持开放态度，所以我不会让它成为我自己问题的答案:

std::vector<std::thread> threads(thread_count);
while(accumulating_data) {
    if(buffer_full) {
        if(threads[thread_id].joinable()) {
            threads[thread_id].join(); }
        }
        threads[thread_id] = std::thread(&MyClass::myfunction, this);
        if(++thread_id == thread_count) { thread_id = 0; }
    }
}

Answer 1

通过引入 std::thread.joinable() 检查，我设法让代码在不崩溃的情况下运行。我仍然对如何更优雅地处理这个问题持开放态度:)

std::vector<std::thread> threads(thread_count);
while(accumulating_data) {
    if(buffer_full) {
        /* the following check returns false prior to an assignment */
        if(threads[thread_id].joinable()) {
            threads[thread_id].join(); }
        }
        threads[thread_id] = std::thread(&MyClass::myfunction, this);
        if(++thread_id == thread_count) { thread_id = 0; }
    }
}