c++ wait如何管理 - 问答

在C++中，等待（wait）通常用于线程同步，以确保一个或多个线程在继续执行之前等待某个条件成立。C++标准库提供了多种等待机制，如条件变量（condition variables）和互斥锁（mutexes）。以下是如何使用这些机制来管理等待的示例：

引入头文件：

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

定义互斥锁和条件变量：

std::mutex mtx; // 互斥锁，用于保护共享资源
std::condition_variable cv; // 条件变量，用于线程间的通信
bool ready = false; // 共享资源，表示条件是否满足

编写生产者和消费者线程函数：

生产者线程函数：

void producer() {
    std::unique_lock<std::mutex> lock(mtx); // 加锁
    std::cout << "生产者生产了一个产品\n";
    ready = true; // 更新共享资源
    cv.notify_one(); // 通知消费者
}

消费者线程函数：

void consumer() {
    std::unique_lock<std::mutex> lock(mtx); // 加锁
    cv.wait(lock, []{ return ready; }); // 等待条件满足
    std::cout << "消费者消费了一个产品\n";
}

在主函数中创建生产者和消费者线程：

int main() {
    std::thread producer_thread(producer);
    std::thread consumer_thread(consumer);

    producer_thread.join();
    consumer_thread.join();

    return 0;
}

在这个示例中，我们使用了std::unique_lock来自动管理互斥锁的锁定和解锁。当消费者线程调用cv.wait()时，它会自动释放互斥锁并进入等待状态。当条件满足时，cv.notify_one()会唤醒一个等待的线程，消费者线程会继续执行并重新获取互斥锁。

注意：在实际应用中，你可能需要根据具体需求调整线程函数和同步机制。例如，你可以使用cv.notify_all()来唤醒所有等待的线程，或者使用std::shared_lock来允许多个线程同时读取共享资源。

0 赞

0 踩