从 n 个线程的段落中读取 m 个单词？ C++ 多线程？不工作？

Question

我想通过使用 Multithreading 一次提取一个单词来阅读一个段落。每个线程应该读一个字，当段落结束时，他们应该和平退出。我知道不应该以这种方式使用线程，因为那样没有优势。但我想这样做，以便在需要时检查线程如何按顺序工作。我试过了，但看起来程序正在进入死锁状态并且根本没有给出任何输出。字符串中有 11 个单词，我正在使用 4 个线程。

#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

您需要更改此代码：

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++;
}

到这里：

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++;
}

上面有三处改变：z 的声明移到循环外，while 中的条件更改为检查z 而不是count，并添加了z+=4 行。如果您希望每个线程移动到下一个单词，则每次需要将 z 增加 4。此外，您需要检查 z 不计数，因为否则某些线程会超调并且最后一个单词将被打印多次（考虑读取第九个单词的线程：如果检查计数而不是 z 它将继续进行下一次迭代循环，即使它没有什么可以读取的了）。