多对一条件线程锁

Question

问题： 首先，这是我的问题的一个简化示例，它实际上是已经由其他人编写的大型框架的一部分，我必须在其中调整我的代码。

我有 3 个功能。其中两个函数（function1 和 function2）被程序的其他部分异步和同步调用。 我的最后一个函数（function3）像一个while循环一样连续运行，它唯一做的就是在每次代码迭代时触发一个事件代码。 我只希望在其他两个函数之一完成迭代/被调用时运行最后一个函数。 我无法更改它们的调用方式/时间，我只能阻止代码的执行并取消阻止它。

我对 c++ 还很陌生，我曾尝试使用互斥锁来解决这个问题，但我没有运气。 我可以添加代码，但它真的就像我解释的那样。

void function1(){  // this function is called by other parts of the program
//some code
}

void funtion2(){  //this function is also called by other parts of the program
//some other code
}

void function3(){ //this function runs continuously, similar to a while loop with a 1ms sleep in it

fireEvent();//fires an event to run some other code
}

所以，function3 一直运行，除非被阻塞，而且我只想在其他函数之一运行一次时运行该函数。就像我之前说的，我不能自己调用​​function3，我只能操作函数中的代码。

最好的方法是什么？

经过激烈的谷歌搜索后，我只提出了条件变量、信号量和互斥锁，但我对它们了解得不够多，不知道如何正确实现它。

非常感谢任何帮助/输入/提示。

Answer 1

一个简单的方法是这样的：

mutex g_mutex;
condition_variable g_cond;
bool flag = false;
void function1(){ // this function is called by other parts of the program
    //some code
    lock_guard<mutex> lock(g_mutex);
    flag = true;
    g_cond.notify_one();
}

void funtion2(){ //this function is also called by other parts of the program
    //some other code
    lock_guard<mutex> lock(g_mutex);
    flag = true;
    g_cond.notify_one();
}

void function3(){ //this function runs continuously, similar to a while loop with a 1ms sleep in it
    {
        unique_lock<mutex> lock(g_mutex);
        g_cond.wait(lock, []{return flag;}); // wait here until func1 or func2 have been called
        flag = false;
    }
    fireEvent();//fires an event to run some other code
}

int main() {
// your code goes here
return 0;
}

但这会阻止您的function3，直到调用其他两个之一。所以这是一种行为的改变，它增加了额外的锁竞争。