为什么我的多线程作业队列崩溃

Why does my multithreaded job queue crash?

本文关键字：崩溃 作业队列 多线程 我的 为什么      更新时间：2023-10-16

我正试图在c++中运行一个多线程作业队列。作为一个例子，我测试了以下程序：

#include <thread>
#include <mutex>
#include <list>
#include <vector>

class Job
{
public:
void Run(void)
{
}
};

class Queue
{
private:
std::recursive_mutex mtxJobs;
std::list<Job *> mJobs;
public:
Job *Take(void)
{
std::scoped_lock(mtxJobs);
if (mJobs.size() > 0)
{
Job *pJob(mJobs.front());
mJobs.pop_front();
return pJob;
}
else
return NULL;
}
void Add(Job *pJob)
{
std::scoped_lock(mtxJobs);
mJobs.push_back(pJob);
}
size_t Size(void)
{
std::scoped_lock(mtxJobs);
return mJobs.size();
}
};

void Work(Queue &q)
{
Job *pJob;
while ((pJob = q.Take()) != NULL)
{
pJob->Run();
delete pJob;
}
}
int main()
{
size_t i;
Queue q;
for (i = 0; i < 1000; i++)
q.Add(new Job);
std::vector<std::thread> threads(4);
for (i = 0; i < 4; i++)
threads[i] = std::thread(Work, std::ref(q));
for (i = 0; i < 4; i++)
threads[i].join();
return 0;
}

当我这样运行它时：

g++ -std=c++17 -lpthread test.cpp -o test && ./test

它与SEGFAULT相撞。有人知道为什么吗？

GDB表示访问列表"mJobs"时总是发生崩溃。但是，锁应该防止并发修改吗？

有人能帮我吗？

您在没有同步的情况下访问队列：

std::scoped_lock(mtxJobs);

这是一个名为mtxJobs的局部变量，创建时不带任何参数，并隐藏互斥对象mtxJobs成员。当创建scoped_lock而不带参数时，它不会根据引用执行任何操作。

你需要写：

std::scoped_lock lock(mtxJobs);

现在，您的互斥锁被锁定在scoped_lock对象的ctor中。

相关文章：