我有这个多线程练习来解决。我必须创建一个类,其中5个线程彼此等待,当第五个线程到达时,它们都被解锁。我想使用互斥和条件变量,但我不知道我是否使用它们。我使用add()方法创建一个类,该方法将variableX递增1,创建一个接收函数print()的线程,然后加入()它。函数print()检查变量X是否为5的小数,如果它类似于条件变量wait,否则条件变量使用notify_all()函数唤醒所有线程。编译器给出了0错误,但是通过调试我看到程序陷入死锁。这是一个片段
#include "stdafx.h"
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
using namespace std;
void print(mutex & mtx, condition_variable & convar, int x) {
if (x < 5){
unique_lock<mutex> lock(mtx); //acquire and lock the mutex
convar.wait(lock); //unlock mutex and wait
}
else {
convar.notify_all();
cout << "asdasd" << endl;
}
}
class foo {
public:
void add() {
this->x = x + 1;
thread t1(print, ref(mtx), ref(cv), x);
t1.join();
}
private:
mutex mtx;
condition_variable cv;
int x;
};
int main() {
foo f;
f.add();
f.add();
f.add();
f.add();
f.add();
}
你的功能
void add() { this->x = x + 1; thread t1(print, ref(mtx), ref(cv), x); t1.join(); }
创建一个线程,然后等待(join()
)直到线程结束。既然你的线程功能
void print(mutex & mtx, condition_variable & convar, int x) { if (x < 5){ unique_lock<mutex> lock(mtx); convar.wait(lock); // waits if x < 5 } // ...
和x
是可能的(你没有初始化它)<5你有你的僵局。
#include <iostream>
#include <thread>
#include <mutex>
#include <vector>
#include <condition_variable>
using namespace std;
void print(mutex & mtx, condition_variable & convar, int x)
{
if (x < 5) {
unique_lock<mutex> lock{ mtx };
convar.wait(lock);
} else {
convar.notify_all();
cout << "asdasd\n";
}
}
class foo {
private:
mutex mtx;
condition_variable cv;
int x{ 0 };
std::vector<thread> threads;
public:
void add() {
++x;
threads.push_back(thread(print, ref(mtx), ref(cv), x));
}
~foo() {
for (auto &t : threads)
t.join();
}
};
int main() {
foo f;
f.add();
f.add();
f.add();
f.add();
f.add();
}