C++11的线程间通信之消息队列 |21xrx.com

C++11的线程间通信之消息队列

2023-07-03 11:13:59 深夜i -- --

C++11 线程间通信消息队列

C++11是一种强大的编程语言，其最新版本还引入了许多新功能，让编程更加便捷和高效。其中，线程间通信是C++11的重要特性之一，开发人员可以通过这种特性来实现线程之间的数据交换和共享。而其中一个常用的线程间通信方式就是消息队列。

消息队列是一种异步通信的方式，它可以让不同的线程之间在不同的时间、不同的速度和不同的优先级下进行通信。通过消息队列，一个线程可以把消息放进队列，另一个线程可以从队列中取出这个消息。这样就实现了两个线程之间的数据交换和共享。

在C++11中，实现消息队列可以使用std::queue和std::mutex来实现。std::queue是一个标准库容器，用于存储和操作队列中的元素。而std::mutex是C++11引入的互斥量，用于保护共享资源的访问。通过将这两个工具结合在一起，就可以实现消息队列。

示例代码如下：


#include <iostream>
#include <queue>
#include <mutex>
#include <thread>
#include <condition_variable>
std::queue<int> message_queue;
std::mutex message_mutex;
std::condition_variable message_cv;
void producer() {
  for(int i = 0; i < 10; ++i) {
    std::unique_lock<std::mutex> lock(message_mutex);
    message_queue.push(i);
    lock.unlock();
    message_cv.notify_one();
    std::this_thread::sleep_for(std::chrono::seconds(1));
  }
}
void consumer() {
  while(true) {
    std::unique_lock<std::mutex> lock(message_mutex);
    message_cv.wait(lock, []{ return !message_queue.empty(); });
    int message = message_queue.front();
    message_queue.pop();
    lock.unlock();
    std::cout << "Received message: " << message << std::endl;
  }
}
int main() {
  std::thread producer_thread(producer);
  std::thread consumer_thread(consumer);
  producer_thread.join();
  consumer_thread.join();
  return 0;
}

在这个示例代码中，producer和consumer是两个线程，它们运行在不同的时间、速度和优先级下。producer线程向消息队列中不断地推送消息，consumer线程则不断地从队列中取出消息并做出相应的处理。在这个过程中，std::mutex和std::condition_variable保证了消息队列的同步和互斥访问。

总之，C++11的消息队列是一种非常强大和灵活的线程间通信方式，它可以让不同的线程之间高效地交换数据和共享资源。开发人员可以通过std::queue和std::mutex来实现消息队列，并使用std::condition_variable来确保消息队列的同步和互斥访问。如果您需要在C++11中实现线程间通信，那么消息队列绝对是一个不错的选择。

上一篇: idea打包java可执行jar包

下一篇: 「简单实现的C++小游戏」

评论区

()

相似文章