c++使用mutex进行进程同步

最近一段时间在做SLAM有关的东西，研究源码的时候碰到了一段和c++的进程同步有关的代码，主要是有一个线程会获取待处理的图像&接收处理后的图像（main），另一个线程（process）获取图像后进行处理然后输出，图片的输入和输出都是典型的生产者消费者问题，所以两个线程用mutex进行同步。稍微花了一点功夫才缕清楚，所以这里专门自己写了一个demo研究c++进程同步的问题。

其中c++的unique_lock是一个非常有趣的机制，当函数开始执行这个函数时，unique_lock自动对信号量加锁，函数执行完毕后，unique_lock自动解锁。

mutex信号量是操作系统里面的概念，用于处理临界资源，在访问临界资源时未获得信号量的进程会被阻塞。

#include <iostream>
#include <thread>
#include <mutex>

bool new_flag = false;
bool processed_flag = false;

std::mutex get_mutex;
std::mutex produce_mutex;

int i;

bool produce_new_object()
{
    std::unique_lock<std::mutex> lock(get_mutex);
    new_flag = true;
}

bool get_processed_object()
{
    std::unique_lock<std::mutex> lock(produce_mutex);
    if(processed_flag)
    {
        processed_flag = false;
        return true;
    }
    return false;
}

bool get_new_object()
{
    std::unique_lock<std::mutex> lock(get_mutex);
    if(new_flag)
    {
        new_flag = false;
        return true;
    }
    return false;
}

bool produce_processed_object()
{
    std::unique_lock<std::mutex> lock(produce_mutex);
    processed_flag = true;
}

void process()
{
    while(1)
    {
        while(!get_new_object());
        std::cout << "process the object " << i << std::endl;
        produce_processed_object();
    }
}

int main(int argc, char const *argv[])
{
    std::thread *t1;
    t1 = new std::thread(&process);

    for (i = 10; i > 0; i--)
    {
        produce_new_object();
        while(!get_processed_object());
    }
    return 0;
}