C++ - Verknüpfen Sie einen Vektor von Threads

Question

Ich verwende g ++ 4.8, um ein C++ 11-Programm zu schreiben. Ich versuche, ein einzelnes Thread-Programm in Multi-Thread-Programm zu konvertieren. Der Join in der Threaded-Version endet mit einem Kompilierungsfehler. Könnten Sie mir bitte sagen, wo ich falsch liege?

Single Threaded (funktioniert gut): Beachten Sie, dass alle Argumente durch Verweis übergeben werden.

for (const auto& i : vec_clients) 
{ 
    i->startSim(vec_masters, vec_trace1, vec_trace2, vec_trace3); 
} 

Multi-Threaded-Version:

std::vector<std::thread> vec_thr; 
for (const auto& i : vec_clients) 
{ 
    std::thread t1(&Client::startSim, std::move(i), std::move(vec_trace1), std::move(vec_trace2), std::move(vec_trace3)); 
    vec_thr.push_back(std::move(t1)); 
} 
for (unsigned int i=0; i<vec_thr.size(); ++i) 
{ 
    // if (i.joinable()) 
     vec_thr.at(i).join(); 
} 

Modified (einfacheres Beispiel):

class Test 
{ 
private: 
public: 
    void testme(const std::string& _str) 
    { 
     std::cout << "Hello "+_str << std::endl; 
    } 
}; 

int main(const int argc, const char **argv) 
{ 
    std::string str = "there"; 
    Test t1; 
    std::vector<std::thread> vec_thr; 
std::thread thr1(&Test::testme, std::move(t1), std::cref(str)); 
    vec_thr.push_back(thr1); 
    return 0; 
} 

Answer 1

Falls jemand noch interessiert, ist dies die Antwort lautet:

class Test 
{ 
private: 
public: 
    void testme(const std::string& _str) 
    { 
     std::cout << "Hello "+_str << std::endl; 
    } 

    void testme2(const std::string& _str) 
    { 
     std::cout << "Hello to "+_str << std::endl; 
    } 
}; 

int main(const int argc, const char **argv) 
{ 
    std::string str = "there"; 
    std::unique_ptr<Test> up1(new Test()); 
    std::unique_ptr<Test> up2(new Test()); 
    std::vector<std::thread> vec_thr; 
    std::thread thr1(&Test::testme, std::move(up1), std::ref(str)); 
    std::thread thr2(&Test::testme2, std::move(up2), std::ref(str)); 
    vec_thr.push_back(std::move(thr1)); 
    vec_thr.push_back(std::move(thr2)); 
    for (unsigned int i=0; i<vec_thr.size(); ++i) 
    { 
     vec_thr.at(i).join(); 
    } 
    return 0; 
} 

Answer 2

Integer i hat kein joinable Member-Funktion (oder jede Memberfunktion als es sich um eine primitiver Typ). Es sollte sein:

for (unsigned int i=0; i<vec_thr.size(); ++i) 
{ 
    if (vec_thr[i].joinable()) 
     vec_thr.at(i).join(); 
} 

Oder nur join auf dem Thread verwenden. Ich sehe keinen besonderen Grund zu tun joinable Test hier, wie Sie nicht detaching einer der Threads sind.