c++11多线程编程之condition_variable
2017-03-05 17:15
357 查看
c++11多线程编程之condition_variable
主要从一个问题出发,编写一个程序,开启3个线程,这3个线程的ID分别为A、B、C,每个线程将自己的ID在屏幕上打印10遍,要求输出结果必须按ABC的顺序显示;如:ABCABC….依次递推。这里可以用c++11的条件变量来解决问题。涉及到的知识点包括:
1.std::unique_lock
首先介绍unique_lock,这个是一个独占锁,它的构造函数有这样几种情况:
unique_lock();(1) (since C++11)
unique_lock(
unique_lock&& other );(2)(since C++11)
explicit unique_lock(
mutex_type& m );(3)(since C++11)
unique_lock(
mutex_type& m, std::defer_lock_t
t );(4)(since C++11)
unique_lock(
mutex_type& m, std::try_to_lock_t
t );(5)(since C++11)
unique_lock(
mutex_type& m, std::adopt_lock_t
t );(6)(since C++11)
template< class Rep, class Period >unique_lock(
mutex_type& m,conststd::chrono::duration<Rep,Period>&
timeout_duration );(7)
(since C++11)
template<
class Clock, class Duration >unique_lock(
mutex_type& m,const
std::chrono::time_point<Clock,Duration>& timeout_time
);(8)(since
C++11)
其中比较特别的就是4,5,6,分别表示不拥有mutex,试图拥有锁,把别人的锁过继过来。
7,8就是跟时间相关的锁了。
2.std::condition_variable
其次就是这个东西了,它的用的时候必须先持有一个unique_lock的变量。
3 代码实现
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
主要从一个问题出发,编写一个程序,开启3个线程,这3个线程的ID分别为A、B、C,每个线程将自己的ID在屏幕上打印10遍,要求输出结果必须按ABC的顺序显示;如:ABCABC….依次递推。这里可以用c++11的条件变量来解决问题。涉及到的知识点包括:
1.std::unique_lock
首先介绍unique_lock,这个是一个独占锁,它的构造函数有这样几种情况:
unique_lock();(1) (since C++11)
unique_lock(
unique_lock&& other );(2)(since C++11)
explicit unique_lock(
mutex_type& m );(3)(since C++11)
unique_lock(
mutex_type& m, std::defer_lock_t
t );(4)(since C++11)
unique_lock(
mutex_type& m, std::try_to_lock_t
t );(5)(since C++11)
unique_lock(
mutex_type& m, std::adopt_lock_t
t );(6)(since C++11)
template< class Rep, class Period >unique_lock(
mutex_type& m,conststd::chrono::duration<Rep,Period>&
timeout_duration );(7)
(since C++11)
template<
class Clock, class Duration >unique_lock(
mutex_type& m,const
std::chrono::time_point<Clock,Duration>& timeout_time
);(8)(since
C++11)
其中比较特别的就是4,5,6,分别表示不拥有mutex,试图拥有锁,把别人的锁过继过来。
7,8就是跟时间相关的锁了。
2.std::condition_variable
其次就是这个东西了,它的用的时候必须先持有一个unique_lock的变量。
3 代码实现
#include <iostream> #include <thread> #include <condition_variable> #include <mutex> int g_index = 0; const int g_threads = 5; std::condition_variable cv; std::mutex mx; void func(int i); int main() { std::thread th[g_threads]; for (int i = 0; i < g_threads; i++) { th[i] = std::thread(func, i); } for (int i = 0; i < g_threads; i++) th[i].join(); return 0; } void func(int gi) { for (int i = 0; i < 10; i++) { std::unique_lock<std::mutex> lk(mx); cv.wait(lk, [=]() { return gi == g_index; }); std::cout << (char)('A' + gi); if (g_index == g_threads - 1) std::cout << std::endl; g_index++; g_index %= g_threads; lk.unlock(); cv.notify_all(); } }4 输出
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
ABCDE
相关文章推荐
- C++11多线程(八):std::condition_variable 详解
- C++11 并发指南五(std::condition_variable 详解)
- C++11多线程编程之互斥量
- C++11多线程编程 call_once
- C++11 多线程编程 原子变量
- Java多线程编程--(7)学习Java5.0 并发编程包--Lock & Condition
- c++11 多线程编程--原子
- c++11中condition_variable信号量的标准用法。
- c++11 之 std::condition_variable
- c++11 条件变量 std::condition_variable,多线程同步
- C++11 多线程编程《C++ Concurrency in Action》读书笔记(1)-Hello World of Concurrency in C++
- 多线程编程10.1-----Condition解决面试题
- c++11线程之条件变量condition_variable(二)
- C++11并行编程-条件变量(condition_variable)详细说明
- 并发编程:c++11 多线程中随机数重复问题
- c++11中的thread, mutex, condition_variable讲解
- c++11线程之条件变量condition_variable(一)
- 用c++11的bind,function,boost::condition_variable实现的一个线程安全的任务队列
- C++11 并发编程基础(一):并发、并行与C++多线程
- c++11多线程 生产者-消费者模型/条件变量condition_variable