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


int main() {
  constexpr size_t kLoopNum = 10;
  std::mutex mtx;
  std::condition_variable cv;
  bool ready_flag{false};

  std::thread thd_producer([&]() {
    for (size_t i = 0; i < kLoopNum; i++) {
      std::cout << "producer thread " << i << std::endl;
      std::this_thread::sleep_for(std::chrono::milliseconds(100));

      if (!ready_flag) {
        std::unique_lock<std::mutex> lock;
        ready_flag = true;
        cv.notify_one();
      }
    }
  });

  std::thread thd_consumer([&]() {
    for (size_t i = 0; i < kLoopNum; i++) {
      std::cout << "consumer thread " << i << std::endl;
      std::unique_lock<std::mutex> lock;
      cv.wait(lock, [&]() {
        return !ready_flag;
      });
    }
  });

  thd_producer.join();
  thd_consumer.join();
}

输出信息：

producer thread 0
consumer thread 0
consumer thread 1
consumer thread 2
consumer thread 3
consumer thread 4
consumer thread 5
consumer thread 6
consumer thread 7
consumer thread 8
consumer thread 9
producer thread 1
producer thread 2
producer thread 3
producer thread 4
producer thread 5
producer thread 6
producer thread 7
producer thread 8
producer thread 9

C++11中的lock

  • std::unique_lock
  • std::lock_guard
  • std::scoped_lock
  • std::lock

C++11中的lock都属于资源自动管理（RAII）范畴。
unique_lock 在使用上比lock_guard更具有弹性，和 lock_guard 相比，unique_lock 主要的特色在于：

  1. unique_lock 不一定要拥有 mutex，所以可以透过 default constructor 建立出一个空的 unique_lock。
  2. unique_lock 虽然一样不可复制（non-copyable），但是它是可以转移的（movable）。所以，unique_lock 不但可以被函数回传，也可以放到 STL 的 container 里。
  3. 另外，unique_lock 也有提供 lock()、unlock() 等函数，可以用来加锁解锁mutex，也算是功能比较完整的地方。
  4. unique_lock本身还可以用于std::lock参数，因为其具备lock、unlock、try_lock成员函数,这些函数不仅完成针对mutex的操作还要更新mutex的状态。

conditional_variable的notidy

  1. cv.notify_one
  2. cv.notify_all
  3. std::notify_all_at_thread_exit(…)

参考

原文地址：http://www.cnblogs.com/vaughnhuang/p/16811285.html

1. 本站所有资源来源于用户上传和网络，如有侵权请邮件联系站长！ 2. 分享目的仅供大家学习和交流，请务用于商业用途! 3. 如果你也有好源码或者教程，可以到用户中心发布，分享有积分奖励和额外收入！ 4. 本站提供的源码、模板、插件等等其他资源，都不包含技术服务请大家谅解！ 5. 如有链接无法下载、失效或广告，请联系管理员处理！ 6. 本站资源售价只是赞助，收取费用仅维持本站的日常运营所需！ 7. 如遇到加密压缩包，默认解压密码为"gltf",如遇到无法解压的请联系管理员！ 8. 因为资源和程序源码均为可复制品，所以不支持任何理由的退款兑现，请斟酌后支付下载 声明：如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性