我有以下代码示例,但不确定其是否线程安全。
void remove(/*...*/) {
int a;
float* data;
while (true)
{
unique_lock<mutex> lock1(mu);
cond.wait(lock1,[this](){return count > 0;});
lock1.unlock();
a = std_queue1.front();
data = std_queue2.front();
// process data
unique_lock<mutex> lock2(mu);
std_queue1.pop();
std_queue2.pop();
count--;
lock2.unlock();
cond.notify_all();
}
}
void add(/*...*/){
int a,iterations = 0;
vector<float*> data;
// Allocate some data entries
while (true) {
// set a
unique_lock<mutex> lock1(mu);
std_queue1.push(a);
cond.wait(lock1,[this,&limit]() { return count < limit; });
lock1.unlock();
// Init data
if (iterations++ > 2) {
unique_lock<mutex> lock2(mu);
std_queue2.push(data[/*...*/]);
count++;
lock2.unlock();
cond.notify_all();
}
}
}
remove(...)和add(...)是同一类的函数。每个函数由一个线程执行,并且两个线程访问相同的队列。互斥锁被锁定以推送和弹出队列中的数据,但不用于功能front()。
所以我的问题是:这个示例线程安全吗?还是对front()函数需要互斥体?
函数pop()和push()是否需要互斥锁?