记录:学习多线程(三)传参详解，detach()大坑，成员函数做线程

1、创建和等待多个线程

2、数据共享问题分析

3、共享数据的保护案列代码

#include<map>
#include<string>
#include<thread>
#include<list>
#include<mutex>

using namespace std;
//线程入口函数
void myprint(int inum){
	cout<<"myprint线程开始执行,index="<<inum<<endl;
	//干各种需要的事情
	cout<<"myprint线程结束执行,index="<<inum<<endl;
}
int main(){
	//一：创建和等待多个线程
	vector<thread> mythreads;
	//创建10个线程,线程入口函数统一使用myprint。
	for(int i=0;i<10;i++){
		mythreads.push_back(thread(myprint,i));/*创建 10个线程，同时
		这10个线程已经并开始执行线程*/
	}
	for(auto iter = mythreads.begin();iter!=mythreads.end();++iter){
		iter->join();
	}
	cout<<"i love china"<<endl;//最后执行这句，整个进程退出.
	return 0;

a//多个线程的执行顺序是乱的，跟操作系统内部对线程的运行调度机制有关。
b//主线程等待所有子线程运行结束，最后主线程结束，推荐这种join的写法，更容易写出稳定的程序
c//把thread对象放入容器管理，看起来像个thread数组，这对我们一次创建大量的线程进行管理很方便

#include<map>
#include<string>
#include<thread>
#include<list>
#include<vector>

using namespace std;

vector<int> g_v = {1,2,3};//共享数据,只读
//线程入口函数
void myprint(int inum){
	cout<<"id="<<std::this_thread::get_id()<<"的线程的打印g_v的值"<<g_v[0]<< g_v[1] <<g_v[2]<<endl;
	return;
}
int main(){
	//一：创建和等待多个线程
	vector<thread> mythreads;
	//创建10个线程,线程入口函数统一使用myprint。
	for(int i=0;i<10;i++){
		mythreads.push_back(thread(myprint,i));/*创建 10个线程，同时
		这10个线程已经并开始执行线程*/
	}
	for(auto iter = mythreads.begin();iter!=mythreads.end();++iter){
		iter->join();
	}
	cout<<"i love china"<<endl;//最后执行这句，整个进程退出.
	return 0;
}

//数据共享问题分析

a//只读的数据，是安全稳定的，不需要特别什么处理手段，直接读可以。

b//有读有写：2个线程写，8个线程读，如果代码没有特别的处理，程序肯定奔溃，最简单的不奔溃处理，读的时候不能写，写的时候不能读。2个线程不能同时写，8个线程不能同时读;

//写的动作分10小步；由于任务切换，导致各种诡异发生（最可能的诡异事情还是奔溃）；

//其他案例

//数据共享

//北京-深圳 火车站，10个售票窗口 卖票， 1，2窗口 同时都要订 99座

//共享数据的保护案列代码

//网络游戏服务器.两个自己创建的线程,一个线程收集玩家命令（用一个数据代表玩家发来的命令），并把命令数据写到一个队列中。另外一个线程用来从队列从取出玩家发送的命令，解析，然后执行玩家需要的动作；

//vector:频繁地按顺序插入和删除数据时效率高。

//list:对随机的插入和删除数据效率高

#include<map>
#include<string>
#include<thread>
#include<vector>
#include<list>

using namespace std;

class A{
public:
//把收到的消息（玩家命令）入到一个队列的线程
	void inMsgRecvQueue(){
		for(int i=0;i<100000; ++i){
			cout<<"inMsgRecvQueue()执行，插入一个元素"<<i<<endl;
			msgRecvQueue.push_back(i);/*假设这个数字i就是我们收到的命令
			我直接弄到消息队列里边来*/
		}
	}
	//把数据从消息队列中取出的线程
	void outMsgRecvQueue(){
		for(int i=0;i<100000;i++){
			if(!msgRecvQueue.empty()){
				//消息队列不为空
				int commmand = msgRecvQueue.front();/*返回第一个元素
				，但不检查元素是否存在*/
				msgRecvQueue.pop_front();//移除第一个元素，但不返回;
				//这里就考虑处理数据...
				/...
				
			}else{
				cout<<"outMsgRecvQueue()执行，但目前消息队列中为空"<<i<<endl;
			}
		}
		cout<<"end"<<endl;
	}

private:
	std::list<int> msgRecvQueue: //容器，专门用于代表玩家给咱们发送过来的命令
	
};
int main(){
	A myobja;
	std::thread myOutMsgObj(&A::outMsgRecvQueue,&myobja);/*第二个参数
	是引用，才能保证线程里用的是用一个对象*/
	std:;thread myInMsgObj(&A::inMsgRecvQueue,&myobja);
	myOutMsgObj.join();
	myInMsgObj.join();
	return 0;
}

//准备用成员函数作为线程函数的方法来写线程。
//代码化解决问题，引入一个c++多线程保护共享数据问题概念“互斥量”，往脑袋里记这个词，下一章再讲