1、创建多个线程

多线程的调度由操作系统负责，线程执行的先后没有严格的顺序完全看操作系统和CPU的心情。

#include <iostream>
#include <vector>
#include <thread>void thread_print(int num)
{std::cout << "线程编号 = " << num << ", 开始工作" << std::endl;std::cout << "-----线程编号 = " << num << ", 执行完毕-----" << std::endl;return ;
}int main() {std::cout << "Hello, World!" << std::endl;std::vector<std::thread> thread_vector;for(int i = 0;i < 10;i++){thread_vector.push_back(std::thread(thread_print, i));}for(auto it = thread_vector.begin();it != thread_vector.end();it++){it->join();}std::cout << "main thread executed finish!" << std::endl;return 0;
}

2、数据共享问题

• 只读的数据：是安全稳定的，不需要特别的处理手段，直接大家都读就行。
• 有读有写：2个线程写，8个线程读，由于任务切换可能会导致各种问题出现。此时就需要互斥，读的时候不能写，写的时候不能读。
• 例如对一个queue容器：一个线程放数据一个线程取数据，如果两个线程不互斥那么将会导致错误访问。

#include <iostream>
#include <vector>
#include <thread>
#include <queue>class MessageQueue{
public:void inMsgRecvQueue(){for(int i = 0;i < n;i++){std::cout << "inMsgRecvQueue()执行, 插入一个元素i = " << i << std::endl;q.push(i);}}void outMsgRecvQueue(){for(int i = 0;i < n;i++){if(q.size()){int msg = q.front();q.pop();}else{std::cout << "outMsgRecvQueue()执行, 但此时消息队列中为空" << std::endl;}}}
private:std::queue<int> q;static const int n = 100000;
};int main() {MessageQueue messageQueue;std::thread in_thread(&MessageQueue::inMsgRecvQueue, std::ref(messageQueue));std::thread out_thread(&MessageQueue::outMsgRecvQueue, std::ref(messageQueue));in_thread.join();out_thread.join();return 0;
}