Использование std :: thread с std :: mutex

Question

Я пытаюсь блокировать mutex с независимыми потоками. Требование состоит в том, что у меня много потоков, которые будут запускаться независимо и получать доступ/обновлять общий ресурс. Чтобы убедиться, что рекурсия обновлена ​​с помощью одной задачи, я использовал мьютекс. Однако это не работает.

Я приклеил код, представление о том, что я пытаюсь сделать ниже:

#include <iostream> 
#include <map> 
#include <string> 
#include <chrono> 
#include <thread> 
#include <mutex> 
#include <unistd.h> 


std::mutex mt; 
static int iMem = 0; 
int maxITr = 1000; 


void renum() 
{ 
    // Ensure that only 1 task will update the variable 
    mt.lock(); 
    int tmpMem = iMem; 
    usleep(100); // Make the system sleep/induce delay 
    iMem = tmpMem + 1;  
    mt.unlock(); 
    printf("iMem = %d\n", iMem); 
} 

int main() 
{ 
    for (int i = 0; i < maxITr; i++) { 
     std::thread mth(renum); 
     mth.detach(); // Run each task in an independent thread 
    } 
    return 0; 
} 

но это оканчивающиеся ниже ошибки:

terminate called after throwing an instance of 'std::system_error' 
    what(): Resource temporarily unavailable 

Я хочу знать, если использование от <thread> .detach() Правильно выше? Если я использую .join(), он работает, но я хочу, чтобы каждый поток работал независимо и не дождался завершения потока. Я также хочу знать, что является лучшим способом достижения вышеуказанной логики.

Answer 1

Попробуйте это:

int main() 
{ 
    std::vector<std::thread> mths; 
    mths.reserve(maxITr); 
    for (int i = 0; i < maxITr; i++) { 
    mths.emplace_back(renum); 
    } 
    for (auto& mth : mths) { 
    mth.join(); 
    } 
} 

Таким образом, вы сохраняете контроль над потоками (по не вызывая detach()), и вы можете присоединиться к ним все в конце концов, так что вы знаете, что они выполнили свои задачи.