练习多线程

Exercise of multithreading

本文关键字：多线程 练习      更新时间：2023-10-16

我有这个多线程练习要解决。我必须创建一个类，其中 5 个线程相互等待，当第五个线程到达时，它们全部解锁。 我想使用互斥锁和条件变量，但我不知道我是否很好地使用了它们。 我用 add(( 方法创建了一个类，它将变量 X 递增 1，创建一个接收函数 print(( 的线程，然后 join(( 它。函数 print(( 检查变量 X 是否是 5 的次要变量，如果是这样条件变量等待，否则条件变量使用 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 << "asdasdn";
}
}
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();
}
相关文章：