我正在 vtk/QT 环境中用 c++ 编写程序。然而,这个问题主要是方法/算法的问题。
我试图同步我的三个正在运行的线程:1.线程:一次传输一个样本,并将其添加到“输出”缓冲区 2.线程:一次接收一个样本,并将其添加到“输入”缓冲区 3. 线程:从“输出”和“输入”缓冲区中提取数据,并将它们添加到单独的绘图缓冲区中,以进行渲染。
我希望这些线程同步运行,并尝试了一种方法,在该方法中,我对每个线程使用一个条件变量和一个布尔条件,其中一个线程向下一个发出信号,因此在循环中是第四个,在上面列出的顺序。但是,当我这样做时,我遇到了死锁并且我的程序停止了。我真的很感激这里的一些输入:)
这是我的代码方法:
//布尔变量的初始条件:
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();
}
除此之外,我将样本线程安全地推入和拉出缓冲区。所以这应该不是问题。
期待您的回复!=)