M Wörter aus einem Absatz aus dem n-Thread lesen? C++ Multithreading? Funktioniert nicht?

Question

Ich möchte einen Absatz lesen, indem Sie mit Multithreading ein Wort nach dem anderen extrahieren. Jeder Thread sollte genau ein Wort lesen und wenn der Absatz endet, sollten sie friedlich beendet werden. Ich weiß, dass Threads auf diese Weise nicht verwendet werden sollten, da dies keinen Vorteil bietet. Aber ich möchte das tun, damit ich prüfen kann, wie Threads bei Bedarf sequentiell arbeiten können. Ich habe versucht, aber es sieht so aus, als ob das Programm den Deadlock-Zustand erreicht und überhaupt keine Ausgabe mehr gibt. Es gibt 11 Wörter in der Zeichenfolge und ich verwende 4 Threads.

#include <iostream> 
#include <mutex> 
#include <sstream> 
#include <thread> 
#include <chrono> 
#include <condition_variable> 
using namespace std; 
stringstream s("Japan US Canada UK France Germany China Russia Korea India Nepal"); 
int count = 0; 
string word; 
condition_variable cv; 
mutex m; 
int i = 0; 
bool check_func(int i,int k) 
{ 
    return i == k; 
} 
void print(int k) 
{ 
    while(count < 11) // As there are 11 words 
    { 
    unique_lock<mutex> lk(m); 
    int z = k; 
    cv.wait(lk,[&]{return check_func(i,z);});   // Line 33 
    s >> word; 
    cout<<word<<" "; 
    i++; 
    cv.notify_all(); 
    count++; 
    } 
    return; 
} 
int main() 
{ 
    thread threads[4]; 
    for(int i = 0; i < 4; i++) 
     threads[i] = thread(print,i); 
    for(auto &t : threads) 
     t.join(); 
    return 0; 
} 

Answer 1

Sie müssen diesen Code ändern:

while(count < 11) // As there are 11 words 
{ 
    unique_lock<mutex> lk(m); 
    int z = k; 
    cv.wait(lk,[&]{return check_func(i,z);});   // Line 33 
    s >> word; 
    cout<<word<<" "; 
    i++; 
    cv.notify_all(); 
    count++; 
} 

Um dies:

int z = k; 
while(z < 11) // As there are 11 words 
{ 
    unique_lock<mutex> lk(m); 
    int z = k; 
    cv.wait(lk,[&]{return check_func(i,z);});   // Line 33 
    s >> word; 
    cout<<word<<" "; 
    i++; 
    z+=4; 
    cv.notify_all(); 
    count++; 
} 

Drei Dinge in der oben geändert: die Erklärung von z außerhalb der Schleife bewegt, die Zustand in der while geändert, um z anstelle von count zu überprüfen, und die Zeile z+=4 hinzugefügt. Sie müssen jedes Mal z um 4 erhöhen, wenn Sie möchten, dass sich jeder Ihrer Threads auf das nächste Wort bewegt. Außerdem müssen Sie überprüfen, dass z nicht zählt, da sonst einige der Threads überschwingen und das letzte Wort mehrmals gedruckt wird (beachten Sie den Thread, der das neunte Wort liest): Wenn Sie z statt z prüfen, geht es weiter zur nächsten Iteration der Schleife, obwohl es nichts weiter zu lesen gibt).