四、创建多线程、数据共享

一、创建、等待多线程

后创建的线程不一定比先创检的线程慢。

多个线程的执行顺序是乱的，跟操作系统内部的线程调度机制有关。

把thread放入到容器里进行管理和调度。

#include <iostream>
#include <thread> //线程
#include <vector>
using namespace std;

void myprt(int num){
    cout << "线程开始，线程编号：" << num << endl;
    cout << "线程结束，线程编号：" << num << endl;
    return;
}
int main(){
    //创建多个线程，线程入口函数统一使用myprt
    vector<thread> mythreads;
    for(int i=0;i<10;i++){
        mythreads.push_back(thread(myprt,i));//创建并执行线程
    }
    for(auto iter=mythreads.begin();iter!=mythreads.end();iter++){
        iter->join();//等待10个线程都返回
    }
    cout<<"main end"<<endl;
    return 0;
}

二、数据共享

1、只读数据

#include <iostream>
#include <thread> //线程
#include <vector>
using namespace std;

vector<int> g_v={1,2,3};//共享数据是安全稳定的
void myprt(int num){
    //cout << "线程开始，线程编号：" << num << endl;
    //cout << "线程结束，线程编号：" << num << endl;
    cout<< "id:"<<std::this_thread::get_id()<<"的线程打印g_v的值"<<g_v[0]<<endl;
    return;
}
int main(){
    //创建多个线程，线程入口函数统一使用myprt
    vector<thread> mythreads;
    for(int i=0;i<10;i++){
        mythreads.push_back(thread(myprt,i));//创建并执行线程
    }
    for(auto iter=mythreads.begin();iter!=mythreads.end();iter++){
        iter->join();//等待10个线程都返回
    }
    cout<<"main end"<<endl;
    return 0;
}

2、有读有写

比如两个线程写，8个线程读，肯定会崩溃。

由于任务切换，会导致各种诡异的事情发生。

最简单的不崩溃方法：读的时候不写，写的时候不读，多个线程不能同时写，多个线程不能同时读；

三、共享数据的保护案例代码

c++解决多线程保护共享数据问题的概念：互斥量！

#include <iostream>
#include <thread> //线程
#include <vector>
#include <list>
/*
网络游戏服务器
创建两个线程，一个线程收集玩家命令（用一个数字代表玩家命令），并把命令数据写到一个队列中；
另一个线程从队列中取出玩家发送来的命令，解析，然后执行玩家需要的动作。
list：频繁顺序插入和删除数据时效率高；
vector：频繁随机插入和删除数据时效率高；
准备使用成员函数来作为线程函数
*/
using namespace std;
class A{
public:
    //把收到的消息（玩家命令）让入到一个队列中的线程函数
    void InMsgQue(){
        for(int i=0;i<100;i++){
            cout<<"InMsgQue执行，插入一个元素"<<i<<endl;
            MyQue.push_back(i);//假设i就是命令
        }

    }
    //把数据从消息队列中取出来的线程函数
    void OutMsgQue(){
        for(int i=0;i<100;i++){
            if(!MyQue.empty()){
                //消息不空
                int command = MyQue.front();//返回第一个元素，但是不检查元素是否存在，所以要if先判断
                MyQue.pop_front();
                //接下来就考虑处理数据.........
            }
            else{
                cout << "OutMsgQue执行，但是消息队列为空"<<i << endl;
            }

        }
        cout<<"end"<<endl;
    }
private:
    list<int> MyQue;
};

int main(){
    A myobj;
    std::thread myout(&A::OutMsgQue,&myobj);
    std::thread myin(&A::InMsgQue,&myobj);//必须市引用，才能保证线程用的是同一个对象
    myout.join();
    myin.join();
    cout<<"main end"<<endl;
    return 0;
}

上面代码有个问题，就是收集命令和取出命令是对共享队列同时进行的，同时对同一个数组进行修改，会导致崩溃。

下面请看互斥量！