multithreading - 使用 3 个条件变量同步 3 个线程

标签 multithreading algorithm synchronization mutex condition-variable

我正在 vtk/QT 环境中用 C++ 编写程序。然而,这个问题主要是方法/算法的问题。

我试图同步我的三个正在运行的线程: 1.线程:一次传输一个样本,并将其添加到“输出”缓冲区 2.线程:一次接收一个样本,并将其添加到“输入”缓冲区 3. 线程:从“输出”和“输入”缓冲区中提取数据,并将它们转换到单独的绘图缓冲区,以进行渲染。

我希望这些线程同步运行,因此尝试了一种方法,我将一个条件变量与每个线程的 bool 条件一起使用,其中一个线程向下一个线程发出信号,循环中的第四个线程, 按照上面列出的顺序。但是,当我这样做时,我遇到了死锁并且我的程序停止了。我真的很感激这里的一些输入:)

这是我的代码方法:

// bool 变量的初始条件:

readyForTransmit=true;
readyForReceive=false;
readyForPlotting=false;

线程 1 - 传输:

while(1){
mutex->Lock();
//waits for condition/signal to proceed
while(!readyForTransmit)
    transmitConditionVariable->wait(mutex);
readyForTransmit=false;
mutex->Unlock();

//Here I transmit my sample
transmit();

//Triggers next thread - reception
mutex->Lock();
readyForReceive=true;
receiveConditionVariable->broadcast(); //Have also tried signal();
mutex->Unlock();
}

线程 2 - 接收:

while(1){
mutex->Lock();
//waits for condition/signal to proceed
while(!readyForReceive)
    receiveConditionVariable->wait(mutex);
readyForReceive=false;
mutex->Unlock();

//Here I receive my sample
receive();

//Triggers next thread - reception
mutex->Lock();
readyForPlotting=true;
plottingConditionVariable->broadcast(); //Have also tried signal();
mutex->Unlock();
}

线程 3 - 添加到绘图缓冲区:

while(1){
mutex->Lock();
//waits for condition/signal to proceed
while(!readyForPlotting)
    plottingConditionVariable->wait(mutex);
readyForPlotting=false;
mutex->Unlock();

//Here I adds samples to plotting buffer
updatePlottingBuffers();

//Triggers next thread - reception
mutex->Lock();
readyForTransmit=true;
transmitConditionVariable->broadcast(); //Have also tried signal();
mutex->Unlock();
}

除此之外,我还以线程安全的方式将样本推送到缓冲区和从缓冲区中提取样本。所以这应该不是问题。

希望收到您的来信! =)

最佳答案

  1. 快速回答:当您已经拥有锁时,不要等待变量为真。如果在进入 mutex->Lock() 区域后 readyForTransmit 不为真,它永远不会为真,因为没有其他线程可以进入它们的 mutex->Lock() 区域来设置它。

  2. 你似乎同步了线程,所以你总是只传输一个项目,然后接收一个项目,然后绘制它。这不是并行行为,您可以将它们放在一个线程中,这样会更容易、更高效。

  3. 我假设这只是测试代码,您会希望在不等待绘图线程的情况下将多个项目传输到缓冲区中。在这种情况下,您的问题看起来完全像消费者-生产者问题,即使用信号量进行同步的教科书示例。您可以在此维基百科页面上找到几种可能的解决方案: https://en.wikipedia.org/wiki/Producer%E2%80%93consumer_problem 或者你可以只用谷歌搜索 Consumer-Producer,你会找到很多好的答案。

关于multithreading - 使用 3 个条件变量同步 3 个线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17719767/

相关文章:

algorithm - 计算可见 GPS 卫星的库或算法

ios - 滚动从远程服务器加载大量图像的 UICollectionView 时如何避免内存问题?

c++ - 将整数范围划分为几乎相等的整数范围

algorithm - 给定一个未排序的整数数组 A,返回一个数组 B,其中 B[i] 是 A[j] 的数量,使得 A[i] > A[j] 而 i < j

actionscript-3 - 多个应用程序的同步和计时

php - fatal error : Call to undefined function sem_get()

java - 是否可以在两个不同的设备上创建同步随机数?

C# - 从工作线程而不是主线程访问时,类字段为空

java - 线程绘制方法

python - 在主线程中使用 KeyboardException 中断 Python 中的线程