gpt4 book ai didi

c++ - 互斥作为类的成员

转载 作者:太空宇宙 更新时间:2023-11-04 14:52:21 24 4
gpt4 key购买 nike

我正在尝试制作一个简单的订阅者-生产者模式,其中多个订阅者和一个生产者在不同的线程中运行(原因是要了解有关线程的更多信息)。然而,我正在努力使互斥量成为生产者类的成员。代码如下:

class Producer {
private:
vector<Subscriber* > subs;
thread th;
int counter;
mutex mux;

public:
Producer() : counter(counter), th(&Producer::run, this) {};
void addSubscriber(Subscriber* s);
void notify();
void incrementCounter();
void run();
void callJoin(){th.join(); }
};

void Producer::run() {
for (int i = 0; i < 10; i++) {
incrementCounter();
this_thread::sleep_for(std::chrono::milliseconds(3000));
}
}

void Producer::addSubscriber(Subscriber* s) {
lock_guard<mutex> lock(mux);
subs.push_back(s);
}

void Producer::notify() {
lock_guard<mutex> lock(mux);
for (auto it = subs.begin(); it != subs.end(); ++it) {
(*it)->setCounterCopy(counter);
}
}

void Producer::incrementCounter() {
counter++;
notify();
}

订阅者类:

class Subscriber {
private:
string name;
thread th;
atomic<int> counterCopy = 0;

public:

Subscriber(string name) : name(name), th(&Subscriber::run, this) {};
void run() {
while (true) {
cout << name << ": " << counterCopy << endl;
this_thread::sleep_for(std::chrono::milliseconds(1000));
}
}
void callJoin() { th.join(); }
void setCounterCopy(int counterCopy) { this->counterCopy = counterCopy; };
};

主要内容:

int main() {
Producer p;
Subscriber s1("Sub1");
p.addSubscriber(&s1);
s1.callJoin();
p.callJoin();
return 0;
}

lock_guard 的目的是防止生产者在将订阅者添加到 vector 时同时通知 vector 中的订阅者。然而这个异常是在 notify 的 lock_guard 中抛出的 Exception thrown at 0x59963734 (msvcp140d.dll) in Project1.exe: 0xC0000005: Access violation reading location 0x00000000. 有谁知道这个异常的原因是什么?如果将互斥量设置为全局参数,则效果很好。也可以随意评论代码的其他问题。线程对我来说是全新的。

最佳答案

所以这里发生的是一个古怪的初始化顺序。

类成员按照它们在类中声明的顺序构造。在您的情况下,这首先意味着订阅者 vector ,然后是线程,然后是计数器(!),最后是互斥体。您在构造函数中指定初始值设定项的顺序无关紧要。

但是!构造一个线程对象需要启动线程,运行它的函数。最终,可能会在 Producer 构造函数到达它实际初始化它的位置之前使用互斥锁。因此,您最终使用了一个尚未构造的互斥锁,并且(这不是您问题的原因)也是一个尚未初始化的计数器。

一般来说,当你有一个提到 this 或不同类成员的成员初始值设定项时,你应该小心,包括调用成员函数。它设置了访问未初始化对象的场景。

在您的情况下,只需将互斥锁和计数器成员移动到线程成员之前就足够了。

关于c++ - 互斥作为类的成员,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52003403/

24 4 0