1、c++11标准库中提供了thread,mutex,condition_variable,我们以最新的标准定义消息队列结构。
2、在消息队列中,使用deque保存消息数据。deque为双端队列,在两端添加、删除数据性能非常高。
3、Push方法:生产者发送消息到消息队列。首先请求互斥锁,添加消息后通知条件变量。
4、Pop方法:消费者从消息队列获取消息。如果消息队列为空,则等待条件筐毙险裆变量。这些线程条件变量的控制原语与pthread_mutex, pthread_cond等类似。
5、Empty方法:返回当前消息队列是否为空。
6、最后我们写一个验证程序,主线程创建消息队列对象,并创建消费者线程。主线程发送消息,消费者线程从消息队列中获取消息并打印。
7、消费者线程实现如下图所示,最终程序运行结果正确,消息队列最后为空。