legongju.com
我们一直在努力
2025-02-04 17:55 | 星期二

C++条件变量如何实现线程通信

在C++中,条件变量(condition variable)是一种用于线程同步的机制,它允许一个或多个线程等待某个条件成立

  1. 包含头文件:
#include 
#include 
#include 
#include 
  1. 定义互斥锁(mutex)和条件变量(condition variable):
std::mutex mtx; // 用于保护共享资源的互斥锁
std::condition_variable cv; // 条件变量
bool ready = false; // 共享资源,表示条件是否成立
  1. 编写一个线程函数,该函数将在条件不满足时等待条件变量:
void print_block(int n, char c) {
    std::unique_lock lock(mtx); // 加锁
    while (!ready) { // 当条件不满足时,等待条件变量
        cv.wait(lock); // 释放锁并等待,直到被唤醒
    }
    for (int i = 0; i < n; ++i) {
        std::cout << c;
    }
    std::cout << '\n';
}
  1. 编写一个函数,用于改变共享资源,并通知等待的线程条件已满足:
void go() {
    std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟耗时操作
    {
        std::lock_guard lock(mtx); // 加锁
        ready = true; // 改变共享资源,表示条件已满足
    }
    cv.notify_one(); // 唤醒等待的线程
}
  1. 在主函数中创建线程并调用这些函数:
int main() {
    std::thread th1(print_block, 50, '*'); // 创建线程1,打印50个星号
    std::thread th2(go); // 创建线程2,改变共享资源并通知线程1

    th1.join(); // 等待线程1结束
    th2.join(); // 等待线程2结束

    return 0;
}

在这个示例中,线程1(print_block)将等待条件变量cv,直到线程2(go)改变共享资源ready并通知它。当条件满足时,线程1将继续执行并打印50个星号。

未经允许不得转载 » 本文链接:https://www.legongju.com/article/14170.html

相关推荐

  • c++ mysql库的数据更新与删除操作

    c++ mysql库的数据更新与删除操作

    在C++中,可以使用MySQL C++ Connector库来进行数据更新和删除操作。以下是一个简单的示例代码,展示如何使用MySQL C++ Connector库来进行数据更新和删除操作:<...

  • c++ memset_s与memset有何不同

    c++ memset_s与memset有何不同

    memset_s 和 memset 都是 C++ 中用于设置内存区域的函数,但它们之间存在一些关键差异 安全性:memset_s 是一个更安全的版本,因为它会检查目标缓冲区的大小。如...

  • c++中使用memset_s需要注意什么

    c++中使用memset_s需要注意什么

    在C++中,memset_s函数是一个安全的内存设置函数,它可以防止缓冲区溢出 包含头文件:在使用memset_s之前,请确保已经包含了正确的头文件。对于C++,应该包含头文...

  • c++ memset_s如何安全清零内存

    c++ memset_s如何安全清零内存

    在C++中,memset_s是一个安全的方法来清零内存
    #include
    #include int main() { char buffer[100]; // 填充缓冲区 for (int i = 0; i< sizeof(buffer)...

  • C++互斥锁如何降低开发难度

    C++互斥锁如何降低开发难度

    C++互斥锁(mutex)是一种同步机制,用于在多线程环境中保护共享资源,防止数据竞争和不一致。使用互斥锁可以降低开发难度,因为它提供了一种简单的方法来确保在...

  • C++互斥锁能应用于分布式系统吗

    C++互斥锁能应用于分布式系统吗

    C++的互斥锁(mutex)主要用于解决单机多线程环境下的同步问题,确保在同一时刻只有一个线程能够访问共享资源。然而,在分布式系统中,由于涉及到多个独立的进程...

  • C++互斥锁能提升系统稳定性吗

    C++互斥锁能提升系统稳定性吗

    是的,C++互斥锁(mutex)可以提升系统的稳定性。在多线程编程中,当多个线程访问共享资源时,可能会出现数据竞争(data race)和不一致的问题。互斥锁是一种同步...

  • C++原子操作有哪些使用场景

    C++原子操作有哪些使用场景

    C++11 引入了原子类型(std::atomic),它提供了一种在多线程环境中安全地执行操作的方法。原子操作主要用于以下几种场景: 避免数据竞争:当多个线程同时访问共...