我正在尝试编写一个程序,同时从“仓库”中添加和删除项目。我有一个处理“仓库”操作的“监视器”类:
class Monitor
{
private:
mutex m;
condition_variable cv;
vector<Storage> S;
int counter = 0;
bool busy = false;;
public:
void add(Computer c, int index) {
unique_lock <mutex> lock(m);
if (busy)
cout << "Thread " << index << ": waiting for !busy " << endl;
cv.wait(lock, [&] { return !busy; });
busy = true;
cout << "Thread " << index << ": Request: add " << c.CPUFrequency << endl;
for (int i = 0; i < counter; i++) {
if (S[i].f == c.CPUFrequency) {
S[i].n++;
busy = false; cv.notify_one();
return;
}
}
Storage s;
s.f = c.CPUFrequency;
s.n = 1;
// put the new item in a sorted position
S.push_back(s);
counter++;
busy = false; cv.notify_one();
}
}
线程是这样创建的:
void doThreadStuff(vector<Computer> P, vector <Storage> R, Monitor &S)
{
int Pcount = P.size();
vector<thread> myThreads;
myThreads.reserve(Pcount);
for (atomic<size_t> i = 0; i < Pcount; i++)
{
int index = i;
Computer c = P[index];
myThreads.emplace_back([&] { S.add(c, index); });
}
for (size_t i = 0; i < Pcount; i++)
{
myThreads[i].join();
}
// printing results
}
运行程序产生了以下结果:
我熟悉竞争条件,但这对我来说并不像。我的赌注是与引用相关的东西,因为在结果中我们可以看到对于每个“丢失的线程”(线程 1、3、10、25),我都会得到“重复的线程”(线程 2、9、24、28)。
我曾尝试在函数和循环中创建局部变量,但没有任何改变。
我听说过线程共享内存区域,但我以前的工作应该产生了类似的结果,所以我不认为这里是这种情况,但请随时证明我是错的。
我正在使用 Visual Studio 2017
最佳答案
这里你在循环中通过引用捕获局部变量,它们会在每次循环中被销毁,导致未定义的行为:
for (atomic<size_t> i = 0; i < Pcount; i++)
{
int index = i;
Computer c = P[index];
myThreads.emplace_back([&] { S.add(c, index); });
}
您应该按值捕获 index
和 c
:
myThreads.emplace_back([&S, index, c] { S.add(c, index); });
关于c++线程,重复/缺少线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52678738/