代码之家 › 专栏 › 技术社区 › Alessandro Picardi

多线程操作

condition-variable mutex multithreading c++

Alessandro Picardi · 技术社区 · 8 年前

我有这个多线程的练习要解决。我必须创建一个类,其中5个线程相互等待,当第五个线程到达时,它们都是解锁的。我用add()方法创建了一个类,该方法将variableX增加1,创建了一个线程,该线程接收print()函数,然后再连接它。函数print()检查variableX是否小于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();
}

1 回复 | 直到 8 年前

Swordfish 8 年前

你的职能

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();
}

推荐文章

Adam Rutledge · 让父线程在初始化子线程pthread后等待,直到它从子线程接收到一些信号的最佳方法是什么?

1 年前

middleStackoverflower · 使用arcmutex处理线程的正确方法是什么?[副本]

2 年前

kevin h · std::recursive_mutex是否会导致死锁?

2 年前

fiedel · 为什么互斥锁可以被两个线程锁定?

2 年前

da cheng · 在c++11中使用条件变量使程序陷入死锁

8 年前

Eunjeong Choi · 为什么此代码返回意外结果?(条件变量)

8 年前

Lars Nielsen · 如何将互斥体用作成员变量?“simple\u encoder”的无复制构造函数被隐式删除

8 年前

Razonixx · 从线程内增加全局计数器变量,而不必等待每个线程

8 年前

spraff · 如果其他人正在等待,是否有标准的STL或Qt方法来生成互斥,否则就保留它?

8 年前

Administrator · c#-等待完成2个线程中的1个

8 年前